gwriterproto

Documentation

Index

• func RegisterWriterServer(s *grpc.Server, srv WriterServer)
• type UnimplementedWriterServer
  • func (*UnimplementedWriterServer) Write(ctx context.Context, req *WriteRequest) (*WriteResponse, error)
• type WriteRequest
  • func (*WriteRequest) Descriptor() ([]byte, []int)
  • func (m *WriteRequest) GetPayload() []byte
  • func (*WriteRequest) ProtoMessage()
  • func (m *WriteRequest) Reset()
  • func (m *WriteRequest) String() string
  • func (m *WriteRequest) XXX_DiscardUnknown()
  • func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *WriteRequest) XXX_Merge(src proto.Message)
  • func (m *WriteRequest) XXX_Size() int
  • func (m *WriteRequest) XXX_Unmarshal(b []byte) error
• type WriteResponse
  • func (*WriteResponse) Descriptor() ([]byte, []int)
  • func (m *WriteResponse) GetError() string
  • func (m *WriteResponse) GetErrored() bool
  • func (m *WriteResponse) GetWritten() int32
  • func (*WriteResponse) ProtoMessage()
  • func (m *WriteResponse) Reset()
  • func (m *WriteResponse) String() string
  • func (m *WriteResponse) XXX_DiscardUnknown()
  • func (m *WriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *WriteResponse) XXX_Merge(src proto.Message)
  • func (m *WriteResponse) XXX_Size() int
  • func (m *WriteResponse) XXX_Unmarshal(b []byte) error
• type WriterClient
  • func NewWriterClient(cc grpc.ClientConnInterface) WriterClient
• type WriterServer

Functions

func RegisterWriterServer

func RegisterWriterServer(s *grpc.Server, srv WriterServer)

Types

type UnimplementedWriterServer

type UnimplementedWriterServer struct {
}

UnimplementedWriterServer can be embedded to have forward compatible implementations.

func (*UnimplementedWriterServer) Write

func (*UnimplementedWriterServer) Write(ctx context.Context, req *WriteRequest) (*WriteResponse, error)

type WriteRequest

type WriteRequest struct {
	Payload              []byte   `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteRequest) Descriptor

func (*WriteRequest) Descriptor() ([]byte, []int)

func (*WriteRequest) GetPayload

func (m *WriteRequest) GetPayload() []byte

func (*WriteRequest) ProtoMessage

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset

func (m *WriteRequest) Reset()

func (*WriteRequest) String

func (m *WriteRequest) String() string

func (*WriteRequest) XXX_DiscardUnknown

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal

func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteRequest) XXX_Merge

func (m *WriteRequest) XXX_Merge(src proto.Message)

func (*WriteRequest) XXX_Size

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal

func (m *WriteRequest) XXX_Unmarshal(b []byte) error

type WriteResponse

type WriteResponse struct {
	Written              int32    `protobuf:"varint,1,opt,name=written,proto3" json:"written,omitempty"`
	Error                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Errored              bool     `protobuf:"varint,3,opt,name=errored,proto3" json:"errored,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteResponse) Descriptor

func (*WriteResponse) Descriptor() ([]byte, []int)

func (*WriteResponse) GetError

func (m *WriteResponse) GetError() string

func (*WriteResponse) GetErrored

func (m *WriteResponse) GetErrored() bool

func (*WriteResponse) GetWritten

func (m *WriteResponse) GetWritten() int32

func (*WriteResponse) ProtoMessage

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset

func (m *WriteResponse) Reset()

func (*WriteResponse) String

func (m *WriteResponse) String() string

func (*WriteResponse) XXX_DiscardUnknown

func (m *WriteResponse) XXX_DiscardUnknown()

func (*WriteResponse) XXX_Marshal

func (m *WriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteResponse) XXX_Merge

func (m *WriteResponse) XXX_Merge(src proto.Message)

func (*WriteResponse) XXX_Size

func (m *WriteResponse) XXX_Size() int

func (*WriteResponse) XXX_Unmarshal

func (m *WriteResponse) XXX_Unmarshal(b []byte) error

type WriterClient

type WriterClient interface {
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
}

WriterClient is the client API for Writer service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewWriterClient

func NewWriterClient(cc grpc.ClientConnInterface) WriterClient

type WriterServer

type WriterServer interface {
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
}

WriterServer is the server API for Writer service.