()
| 5533 | } |
| 5534 | |
| 5535 | func (x *raftRaftMessageClient) CloseAndRecv() (*api.Payload, error) { |
| 5536 | if err := x.ClientStream.CloseSend(); err != nil { |
| 5537 | return nil, err |
| 5538 | } |
| 5539 | m := new(api.Payload) |
| 5540 | if err := x.ClientStream.RecvMsg(m); err != nil { |
| 5541 | return nil, err |
| 5542 | } |
| 5543 | return m, nil |
| 5544 | } |
| 5545 | |
| 5546 | func (c *raftClient) JoinCluster(ctx context.Context, in *RaftContext, opts ...grpc.CallOption) (*api.Payload, error) { |
| 5547 | out := new(api.Payload) |
nothing calls this directly
no outgoing calls
no test coverage detected