dcp

Documentation

Overview

Package dcp is a generated protocol buffer package.

It is generated from these files:

protocol/dcp/message.proto

It has these top-level messages:

Message
Payload
Response

Index

• Variables
• func RegisterDCPServiceServer(s *grpc.Server, srv DCPServiceServer)
• type DCPServiceClient
  • func NewDCPServiceClient(cc *grpc.ClientConn) DCPServiceClient
• type DCPServiceServer
• type DCPService_ProcessClient
• type DCPService_ProcessServer
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (m *Message) GetBarrier() uint64
  • func (m *Message) GetBody() isMessage_Body
  • func (m *Message) GetChecksum() string
  • func (m *Message) GetId() string
  • func (m *Message) GetPayload() *Payload
  • func (m *Message) GetTag() string
  • func (m *Message) GetTimestamp() uint64
  • func (m *Message) Marshal() (dAtA []byte, err error)
  • func (m *Message) MarshalTo(dAtA []byte) (int, error)
  • func (*Message) ProtoMessage()
  • func (m *Message) Reset()
  • func (m *Message) Size() (n int)
  • func (m *Message) String() string
  • func (m *Message) Unmarshal(dAtA []byte) error
  • func (*Message) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
• type Message_Barrier
  • func (m *Message_Barrier) MarshalTo(dAtA []byte) (int, error)
  • func (m *Message_Barrier) Size() (n int)
• type Message_Payload
  • func (m *Message_Payload) MarshalTo(dAtA []byte) (int, error)
  • func (m *Message_Payload) Size() (n int)
• type Payload
  • func (*Payload) Descriptor() ([]byte, []int)
  • func (m *Payload) GetContent() string
  • func (m *Payload) GetId() string
  • func (m *Payload) Marshal() (dAtA []byte, err error)
  • func (m *Payload) MarshalTo(dAtA []byte) (int, error)
  • func (*Payload) ProtoMessage()
  • func (m *Payload) Reset()
  • func (m *Payload) Size() (n int)
  • func (m *Payload) String() string
  • func (m *Payload) Unmarshal(dAtA []byte) error
• type Response
  • func (*Response) Descriptor() ([]byte, []int)
  • func (m *Response) GetCode() int32
  • func (m *Response) GetId() string
  • func (m *Response) GetMsg() string
  • func (m *Response) Marshal() (dAtA []byte, err error)
  • func (m *Response) MarshalTo(dAtA []byte) (int, error)
  • func (*Response) ProtoMessage()
  • func (m *Response) Reset()
  • func (m *Response) Size() (n int)
  • func (m *Response) String() string
  • func (m *Response) Unmarshal(dAtA []byte) error

Variables

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

Functions

func RegisterDCPServiceServer

func RegisterDCPServiceServer(s *grpc.Server, srv DCPServiceServer)

Types

type DCPServiceClient

type DCPServiceClient interface {
	Process(ctx context.Context, opts ...grpc.CallOption) (DCPService_ProcessClient, error)
}

func NewDCPServiceClient

func NewDCPServiceClient(cc *grpc.ClientConn) DCPServiceClient

type DCPServiceServer

type DCPServiceServer interface {
	Process(DCPService_ProcessServer) error
}

type DCPService_ProcessClient

type DCPService_ProcessClient interface {
	Send(*Message) error
	Recv() (*Response, error)
	grpc.ClientStream
}

type DCPService_ProcessServer

type DCPService_ProcessServer interface {
	Send(*Response) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type Message

type Message struct {
	Id  string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Tag string `protobuf:"bytes,2,opt,name=tag,proto3" json:"tag,omitempty"`
	// Types that are valid to be assigned to Body:
	//	*Message_Barrier
	//	*Message_Payload
	Body      isMessage_Body `protobuf_oneof:"body"`
	Timestamp uint64         `protobuf:"varint,14,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Checksum  string         `protobuf:"bytes,15,opt,name=checksum,proto3" json:"checksum,omitempty"`
}

func (*Message) Descriptor

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

func (*Message) GetBarrier

func (m *Message) GetBarrier() uint64

func (*Message) GetBody

func (m *Message) GetBody() isMessage_Body

func (*Message) GetChecksum

func (m *Message) GetChecksum() string

func (*Message) GetId

func (m *Message) GetId() string

func (*Message) GetPayload

func (m *Message) GetPayload() *Payload

func (*Message) GetTag

func (m *Message) GetTag() string

func (*Message) GetTimestamp

func (m *Message) GetTimestamp() uint64

func (*Message) Marshal

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

func (*Message) MarshalTo

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

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) Reset

func (m *Message) Reset()

func (*Message) Size

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

func (*Message) String

func (m *Message) String() string

func (*Message) Unmarshal

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

func (*Message) XXX_OneofFuncs

func (*Message) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type Message_Barrier

type Message_Barrier struct {
	Barrier uint64 `protobuf:"varint,3,opt,name=barrier,proto3,oneof"`
}

func (*Message_Barrier) MarshalTo

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

func (*Message_Barrier) Size

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

type Message_Payload

type Message_Payload struct {
	Payload *Payload `protobuf:"bytes,4,opt,name=payload,oneof"`
}

func (*Message_Payload) MarshalTo

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

func (*Message_Payload) Size

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

type Payload

type Payload struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Content string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
}

func (*Payload) Descriptor

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

func (*Payload) GetContent

func (m *Payload) GetContent() string

func (*Payload) GetId

func (m *Payload) GetId() string

func (*Payload) Marshal

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

func (*Payload) MarshalTo

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

func (*Payload) ProtoMessage

func (*Payload) ProtoMessage()

func (*Payload) Reset

func (m *Payload) Reset()

func (*Payload) Size

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

func (*Payload) String

func (m *Payload) String() string

func (*Payload) Unmarshal

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

type Response

type Response struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Code int32  `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	Msg  string `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*Response) Descriptor

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

func (*Response) GetCode

func (m *Response) GetCode() int32

func (*Response) GetId

func (m *Response) GetId() string

func (*Response) GetMsg

func (m *Response) GetMsg() string

func (*Response) Marshal

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

func (*Response) MarshalTo

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

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) Size

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

func (*Response) String

func (m *Response) String() string

func (*Response) Unmarshal

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