proto

type Configure struct {
	// contains filtered or unexported fields
}

type Configure_Request struct {
	Path      string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	ChunkSize int64  `protobuf:"varint,2,opt,name=chunk_size,json=chunkSize,proto3" json:"chunk_size,omitempty"`
	// contains filtered or unexported fields
}

type Configure_Response struct {
	// contains filtered or unexported fields
}

type Read struct {
	// contains filtered or unexported fields
}

type Read_Request struct {
	// contains filtered or unexported fields
}

type Read_ResponseChunk struct {
	ReadBytes []byte `protobuf:"bytes,1,opt,name=read_bytes,json=readBytes,proto3" json:"read_bytes,omitempty"`
	// contains filtered or unexported fields
}

type StreamerServiceClient interface {
	Configure(ctx context.Context, in *Configure_Request, opts ...grpc.CallOption) (*Configure_Response, error)
	Read(ctx context.Context, in *Read_Request, opts ...grpc.CallOption) (StreamerService_ReadClient, error)
	Write(ctx context.Context, opts ...grpc.CallOption) (StreamerService_WriteClient, error)
}

type StreamerServiceServer interface {
	Configure(context.Context, *Configure_Request) (*Configure_Response, error)
	Read(*Read_Request, StreamerService_ReadServer) error
	Write(StreamerService_WriteServer) error
	// contains filtered or unexported methods
}

type StreamerService_ReadClient interface {
	Recv() (*Read_ResponseChunk, error)
	grpc.ClientStream
}

type StreamerService_ReadServer interface {
	Send(*Read_ResponseChunk) error
	grpc.ServerStream
}

type StreamerService_WriteClient interface {
	Send(*Write_RequestChunk) error
	CloseAndRecv() (*Write_Response, error)
	grpc.ClientStream
}

type StreamerService_WriteServer interface {
	SendAndClose(*Write_Response) error
	Recv() (*Write_RequestChunk, error)
	grpc.ServerStream
}

type UnimplementedStreamerServiceServer struct {
}

type UnsafeStreamerServiceServer interface {
	// contains filtered or unexported methods
}

type Write struct {
	// contains filtered or unexported fields
}

type Write_RequestChunk struct {
	BytesToWrite []byte `protobuf:"bytes,1,opt,name=bytes_to_write,json=bytesToWrite,proto3" json:"bytes_to_write,omitempty"`
	// contains filtered or unexported fields
}

type Write_Response struct {
	// contains filtered or unexported fields
}