testutil

Documentation

Index

• type FakeByteStreamClient
  • func (c *FakeByteStreamClient) QueryWriteStatus(ctx context.Context, in *bytestream.QueryWriteStatusRequest, ...) (*bytestream.QueryWriteStatusResponse, error)
  • func (c *FakeByteStreamClient) Read(ctx context.Context, in *bytestream.ReadRequest, opts ...grpc.CallOption) (bytestream.ByteStream_ReadClient, error)
  • func (c *FakeByteStreamClient) Write(ctx context.Context, opts ...grpc.CallOption) (bytestream.ByteStream_WriteClient, error)
• type FakeCASReader
  • func (r *FakeCASReader) Recv() (*bytestream.ReadResponse, error)

Types

type FakeByteStreamClient

type FakeByteStreamClient struct {
	ExtraResponseData []byte
}

func (*FakeByteStreamClient) QueryWriteStatus

func (c *FakeByteStreamClient) QueryWriteStatus(ctx context.Context, in *bytestream.QueryWriteStatusRequest, opts ...grpc.CallOption) (*bytestream.QueryWriteStatusResponse, error)

func (*FakeByteStreamClient) Read

func (c *FakeByteStreamClient) Read(ctx context.Context, in *bytestream.ReadRequest, opts ...grpc.CallOption) (bytestream.ByteStream_ReadClient, error)

func (*FakeByteStreamClient) Write

func (c *FakeByteStreamClient) Write(ctx context.Context, opts ...grpc.CallOption) (bytestream.ByteStream_WriteClient, error)

type FakeCASReader

type FakeCASReader struct {
	grpc.ClientStream // implements the rest of grpc.ClientStream

	Res         []*bytestream.ReadResponse
	ResIndex    int
	ResDataPos  int
	ResErr      error
	ResErrIndex int

	ReadLimit int
	// contains filtered or unexported fields
}

func (*FakeCASReader) Recv

func (r *FakeCASReader) Recv() (*bytestream.ReadResponse, error)