CpiInterfaceClient is the client API for CpiInterface service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
| 19 | // |
| 20 | // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. |
| 21 | type CpiInterfaceClient interface { |
| 22 | OnMetricsReceive(ctx context.Context, in *AutoscalingMetric, opts ...grpc.CallOption) (*ActionStatus, error) |
| 23 | ListServices(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ServiceList, error) |
| 24 | RegisterDataplane(ctx context.Context, in *DataplaneInfo, opts ...grpc.CallOption) (*ActionStatus, error) |
| 25 | RegisterService(ctx context.Context, in *ServiceInfo, opts ...grpc.CallOption) (*ActionStatus, error) |
| 26 | RegisterNode(ctx context.Context, in *NodeInfo, opts ...grpc.CallOption) (*ActionStatus, error) |
| 27 | NodeHeartbeat(ctx context.Context, in *NodeHeartbeatMessage, opts ...grpc.CallOption) (*ActionStatus, error) |
| 28 | ReportFailure(ctx context.Context, in *Failure, opts ...grpc.CallOption) (*ActionStatus, error) |
| 29 | DeregisterDataplane(ctx context.Context, in *DataplaneInfo, opts ...grpc.CallOption) (*ActionStatus, error) |
| 30 | DeregisterNode(ctx context.Context, in *NodeInfo, opts ...grpc.CallOption) (*ActionStatus, error) |
| 31 | DeregisterService(ctx context.Context, in *ServiceInfo, opts ...grpc.CallOption) (*ActionStatus, error) |
| 32 | ResetMeasurements(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ActionStatus, error) |
| 33 | // RAFT leader election |
| 34 | RequestVote(ctx context.Context, in *RequestVoteArgs, opts ...grpc.CallOption) (*RequestVoteReply, error) |
| 35 | AppendEntries(ctx context.Context, in *AppendEntriesArgs, opts ...grpc.CallOption) (*AppendEntriesReply, error) |
| 36 | // HAProxy |
| 37 | ReviseHAProxyConfiguration(ctx context.Context, in *HAProxyConfig, opts ...grpc.CallOption) (*ActionStatus, error) |
| 38 | } |
| 39 | |
| 40 | type cpiInterfaceClient struct { |
| 41 | cc grpc.ClientConnInterface |
no outgoing calls
no test coverage detected