payload

Documentation

Overview

Package payload is a generated protocol buffer package.

It is generated from these files:

payload.proto

It has these top-level messages:

WriteRequest
WriteResponse

Index

• Variables
• func RegisterWriteServer(s *grpc.Server, srv WriteServer)
• type WriteClient
  • func NewWriteClient(cc *grpc.ClientConn) WriteClient
• type WriteRequest
  • func (*WriteRequest) Descriptor() ([]byte, []int)
  • func (m *WriteRequest) Marshal() (dAtA []byte, err error)
  • func (m *WriteRequest) MarshalTo(dAtA []byte) (int, error)
  • func (*WriteRequest) ProtoMessage()
  • func (m *WriteRequest) Reset()
  • func (m *WriteRequest) Size() (n int)
  • func (m *WriteRequest) String() string
  • func (m *WriteRequest) Unmarshal(dAtA []byte) error
• type WriteResponse
  • func (*WriteResponse) Descriptor() ([]byte, []int)
  • func (m *WriteResponse) Marshal() (dAtA []byte, err error)
  • func (m *WriteResponse) MarshalTo(dAtA []byte) (int, error)
  • func (*WriteResponse) ProtoMessage()
  • func (m *WriteResponse) Reset()
  • func (m *WriteResponse) Size() (n int)
  • func (m *WriteResponse) String() string
  • func (m *WriteResponse) Unmarshal(dAtA []byte) error
• type WriteServer

Variables

var (
	ErrInvalidLengthPayload = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPayload   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterWriteServer

func RegisterWriteServer(s *grpc.Server, srv WriteServer)

Types

type WriteClient

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

func NewWriteClient

func NewWriteClient(cc *grpc.ClientConn) WriteClient

type WriteRequest

type WriteRequest struct {
	IntSeries    []common.IntSeries    `protobuf:"bytes,1,rep,name=intSeries" json:"intSeries"`
	DoubleSeries []common.DoubleSeries `protobuf:"bytes,2,rep,name=doubleSeries" json:"doubleSeries"`
}

func (*WriteRequest) Descriptor

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

func (*WriteRequest) Marshal

func (m *WriteRequest) Marshal() (dAtA []byte, err error)

func (*WriteRequest) MarshalTo

func (m *WriteRequest) MarshalTo(dAtA []byte) (int, error)

func (*WriteRequest) ProtoMessage

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset

func (m *WriteRequest) Reset()

func (*WriteRequest) Size

func (m *WriteRequest) Size() (n int)

func (*WriteRequest) String

func (m *WriteRequest) String() string

func (*WriteRequest) Unmarshal

func (m *WriteRequest) Unmarshal(dAtA []byte) error

type WriteResponse

type WriteResponse struct {
	Error    bool   `protobuf:"varint,1,opt,name=error,proto3" json:"error,omitempty"`
	ErrorMsg string `protobuf:"bytes,2,opt,name=errorMsg,proto3" json:"errorMsg,omitempty"`
}

func (*WriteResponse) Descriptor

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

func (*WriteResponse) Marshal

func (m *WriteResponse) Marshal() (dAtA []byte, err error)

func (*WriteResponse) MarshalTo

func (m *WriteResponse) MarshalTo(dAtA []byte) (int, error)

func (*WriteResponse) ProtoMessage

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset

func (m *WriteResponse) Reset()

func (*WriteResponse) Size

func (m *WriteResponse) Size() (n int)

func (*WriteResponse) String

func (m *WriteResponse) String() string

func (*WriteResponse) Unmarshal

func (m *WriteResponse) Unmarshal(dAtA []byte) error

type WriteServer

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