CpiInterfaceServer is the server API for CpiInterface service. All implementations must embed UnimplementedCpiInterfaceServer for forward compatibility
| 175 | // All implementations must embed UnimplementedCpiInterfaceServer |
| 176 | // for forward compatibility |
| 177 | type CpiInterfaceServer interface { |
| 178 | OnMetricsReceive(context.Context, *AutoscalingMetric) (*ActionStatus, error) |
| 179 | ListServices(context.Context, *emptypb.Empty) (*ServiceList, error) |
| 180 | RegisterDataplane(context.Context, *DataplaneInfo) (*ActionStatus, error) |
| 181 | RegisterService(context.Context, *ServiceInfo) (*ActionStatus, error) |
| 182 | RegisterNode(context.Context, *NodeInfo) (*ActionStatus, error) |
| 183 | NodeHeartbeat(context.Context, *NodeHeartbeatMessage) (*ActionStatus, error) |
| 184 | ReportFailure(context.Context, *Failure) (*ActionStatus, error) |
| 185 | DeregisterDataplane(context.Context, *DataplaneInfo) (*ActionStatus, error) |
| 186 | DeregisterNode(context.Context, *NodeInfo) (*ActionStatus, error) |
| 187 | DeregisterService(context.Context, *ServiceInfo) (*ActionStatus, error) |
| 188 | ResetMeasurements(context.Context, *emptypb.Empty) (*ActionStatus, error) |
| 189 | // RAFT leader election |
| 190 | RequestVote(context.Context, *RequestVoteArgs) (*RequestVoteReply, error) |
| 191 | AppendEntries(context.Context, *AppendEntriesArgs) (*AppendEntriesReply, error) |
| 192 | // HAProxy |
| 193 | ReviseHAProxyConfiguration(context.Context, *HAProxyConfig) (*ActionStatus, error) |
| 194 | mustEmbedUnimplementedCpiInterfaceServer() |
| 195 | } |
| 196 | |
| 197 | // UnimplementedCpiInterfaceServer must be embedded to have forward compatible implementations. |
| 198 | type UnimplementedCpiInterfaceServer struct { |
nothing calls this directly
no outgoing calls
no test coverage detected