mock

Documentation

Index

• type Addr
  • func (Addr) Network() string
  • func (Addr) String() string
• type ErrorWALStreamServer
  • func (m *ErrorWALStreamServer) Send(*proto.GetWALStreamResponse) error
• type GetClientAddrErrorWALStreamServer
  • func (m *GetClientAddrErrorWALStreamServer) Context() context.Context
• type ReplicationClient
  • func (rc ReplicationClient) GetWALStream(_ context.Context, in *pb.GetWALStreamRequest, _ ...grpc.CallOption) (pb.Replication_GetWALStreamClient, error)
• type WALStreamClient
  • func (wsc *WALStreamClient) CloseSend() error
  • func (wsc *WALStreamClient) Context() context.Context
  • func (wsc *WALStreamClient) Header() (metadata.MD, error)
  • func (wsc *WALStreamClient) Recv() (*pb.GetWALStreamResponse, error)
  • func (wsc *WALStreamClient) RecvMsg(m interface{}) error
  • func (wsc *WALStreamClient) SendMsg(m interface{}) error
  • func (wsc *WALStreamClient) Trailer() metadata.MD
• type WALStreamServer
  • func (m *WALStreamServer) Context() context.Context
  • func (m *WALStreamServer) RecvMsg(msg interface{}) error
  • func (m *WALStreamServer) Send(resp *proto.GetWALStreamResponse) error
  • func (m *WALStreamServer) SendHeader(metadata.MD) error
  • func (m *WALStreamServer) SendMsg(msg interface{}) error
  • func (m *WALStreamServer) SetHeader(metadata.MD) error
  • func (m *WALStreamServer) SetTrailer(metadata.MD)

Types

type Addr

type Addr struct{}

func (Addr) Network

func (Addr) Network() string

func (Addr) String

func (Addr) String() string

type ErrorWALStreamServer

type ErrorWALStreamServer struct {
	WALStreamServer
}

-------------.

func (*ErrorWALStreamServer) Send

func (m *ErrorWALStreamServer) Send(*proto.GetWALStreamResponse) error

type GetClientAddrErrorWALStreamServer

type GetClientAddrErrorWALStreamServer struct {
	WALStreamServer
}

--------------.

func (*GetClientAddrErrorWALStreamServer) Context

func (m *GetClientAddrErrorWALStreamServer) Context() context.Context

type ReplicationClient

type ReplicationClient struct {
	StreamClient pb.Replication_GetWALStreamClient
	Error        error
}

func (ReplicationClient) GetWALStream

func (rc ReplicationClient) GetWALStream(_ context.Context, in *pb.GetWALStreamRequest, _ ...grpc.CallOption,
) (pb.Replication_GetWALStreamClient, error)

type WALStreamClient

type WALStreamClient struct {
	Response *pb.GetWALStreamResponse
	Error    error
}

func (*WALStreamClient) CloseSend

func (wsc *WALStreamClient) CloseSend() error

func (*WALStreamClient) Context

func (wsc *WALStreamClient) Context() context.Context

func (*WALStreamClient) Header

func (wsc *WALStreamClient) Header() (metadata.MD, error)

func (*WALStreamClient) Recv

func (wsc *WALStreamClient) Recv() (*pb.GetWALStreamResponse, error)

func (*WALStreamClient) RecvMsg

func (wsc *WALStreamClient) RecvMsg(m interface{}) error

func (*WALStreamClient) SendMsg

func (wsc *WALStreamClient) SendMsg(m interface{}) error

func (*WALStreamClient) Trailer

func (wsc *WALStreamClient) Trailer() metadata.MD

type WALStreamServer

type WALStreamServer struct {
	SendFunc func(resp *proto.GetWALStreamResponse) error
}

func (*WALStreamServer) Context

func (m *WALStreamServer) Context() context.Context

func (*WALStreamServer) RecvMsg

func (m *WALStreamServer) RecvMsg(msg interface{}) error

func (*WALStreamServer) Send

func (m *WALStreamServer) Send(resp *proto.GetWALStreamResponse) error

func (*WALStreamServer) SendHeader

func (m *WALStreamServer) SendHeader(metadata.MD) error

func (*WALStreamServer) SendMsg

func (m *WALStreamServer) SendMsg(msg interface{}) error

func (*WALStreamServer) SetHeader

func (m *WALStreamServer) SetHeader(metadata.MD) error

------------.

func (*WALStreamServer) SetTrailer

func (m *WALStreamServer) SetTrailer(metadata.MD)