proto

README

protoc pkg/dispatcher/proto/dispatcher.proto --go_out=plugins=grpc:.

Documentation

Index

• func RegisterDispatcherServiceServer(s *grpc.Server, srv DispatcherServiceServer)
• type DispatcherCommandReply
  • func (*DispatcherCommandReply) Descriptor() ([]byte, []int)
  • func (m *DispatcherCommandReply) GetData() []byte
  • func (m *DispatcherCommandReply) GetOP() string
  • func (*DispatcherCommandReply) ProtoMessage()
  • func (m *DispatcherCommandReply) Reset()
  • func (m *DispatcherCommandReply) String() string
  • func (m *DispatcherCommandReply) XXX_DiscardUnknown()
  • func (m *DispatcherCommandReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *DispatcherCommandReply) XXX_Merge(src proto.Message)
  • func (m *DispatcherCommandReply) XXX_Size() int
  • func (m *DispatcherCommandReply) XXX_Unmarshal(b []byte) error
• type DispatcherCommandRequest
  • func (*DispatcherCommandRequest) Descriptor() ([]byte, []int)
  • func (m *DispatcherCommandRequest) GetData() []byte
  • func (m *DispatcherCommandRequest) GetMerchantID() string
  • func (m *DispatcherCommandRequest) GetOP() string
  • func (m *DispatcherCommandRequest) GetSenderFirstName() string
  • func (m *DispatcherCommandRequest) GetSenderID() string
  • func (m *DispatcherCommandRequest) GetSenderLastName() string
  • func (m *DispatcherCommandRequest) GetTargetID() string
  • func (*DispatcherCommandRequest) ProtoMessage()
  • func (m *DispatcherCommandRequest) Reset()
  • func (m *DispatcherCommandRequest) String() string
  • func (m *DispatcherCommandRequest) XXX_DiscardUnknown()
  • func (m *DispatcherCommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *DispatcherCommandRequest) XXX_Merge(src proto.Message)
  • func (m *DispatcherCommandRequest) XXX_Size() int
  • func (m *DispatcherCommandRequest) XXX_Unmarshal(b []byte) error
• type DispatcherServiceClient
  • func NewDispatcherServiceClient(cc *grpc.ClientConn) DispatcherServiceClient
• type DispatcherServiceServer

Functions

func RegisterDispatcherServiceServer

func RegisterDispatcherServiceServer(s *grpc.Server, srv DispatcherServiceServer)

Types

type DispatcherCommandReply

type DispatcherCommandReply struct {
	OP                   string   `protobuf:"bytes,1,opt,name=OP,proto3" json:"OP,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DispatcherCommandReply) Descriptor

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

func (*DispatcherCommandReply) GetData

func (m *DispatcherCommandReply) GetData() []byte

func (*DispatcherCommandReply) GetOP

func (m *DispatcherCommandReply) GetOP() string

func (*DispatcherCommandReply) ProtoMessage

func (*DispatcherCommandReply) ProtoMessage()

func (*DispatcherCommandReply) Reset

func (m *DispatcherCommandReply) Reset()

func (*DispatcherCommandReply) String

func (m *DispatcherCommandReply) String() string

func (*DispatcherCommandReply) XXX_DiscardUnknown

func (m *DispatcherCommandReply) XXX_DiscardUnknown()

func (*DispatcherCommandReply) XXX_Marshal

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

func (*DispatcherCommandReply) XXX_Merge

func (dst *DispatcherCommandReply) XXX_Merge(src proto.Message)

func (*DispatcherCommandReply) XXX_Size

func (m *DispatcherCommandReply) XXX_Size() int

func (*DispatcherCommandReply) XXX_Unmarshal

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

type DispatcherCommandRequest

type DispatcherCommandRequest struct {
	OP                   string   `protobuf:"bytes,1,opt,name=OP,proto3" json:"OP,omitempty"`
	MerchantID           string   `protobuf:"bytes,2,opt,name=MerchantID,proto3" json:"MerchantID,omitempty"`
	SenderID             string   `protobuf:"bytes,3,opt,name=SenderID,proto3" json:"SenderID,omitempty"`
	SenderFirstName      string   `protobuf:"bytes,4,opt,name=SenderFirstName,proto3" json:"SenderFirstName,omitempty"`
	SenderLastName       string   `protobuf:"bytes,5,opt,name=SenderLastName,proto3" json:"SenderLastName,omitempty"`
	TargetID             string   `protobuf:"bytes,6,opt,name=TargetID,proto3" json:"TargetID,omitempty"`
	Data                 []byte   `protobuf:"bytes,7,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DispatcherCommandRequest) Descriptor

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

func (*DispatcherCommandRequest) GetData

func (m *DispatcherCommandRequest) GetData() []byte

func (*DispatcherCommandRequest) GetMerchantID

func (m *DispatcherCommandRequest) GetMerchantID() string

func (*DispatcherCommandRequest) GetOP

func (m *DispatcherCommandRequest) GetOP() string

func (*DispatcherCommandRequest) GetSenderFirstName

func (m *DispatcherCommandRequest) GetSenderFirstName() string

func (*DispatcherCommandRequest) GetSenderID

func (m *DispatcherCommandRequest) GetSenderID() string

func (*DispatcherCommandRequest) GetSenderLastName

func (m *DispatcherCommandRequest) GetSenderLastName() string

func (*DispatcherCommandRequest) GetTargetID

func (m *DispatcherCommandRequest) GetTargetID() string

func (*DispatcherCommandRequest) ProtoMessage

func (*DispatcherCommandRequest) ProtoMessage()

func (*DispatcherCommandRequest) Reset

func (m *DispatcherCommandRequest) Reset()

func (*DispatcherCommandRequest) String

func (m *DispatcherCommandRequest) String() string

func (*DispatcherCommandRequest) XXX_DiscardUnknown

func (m *DispatcherCommandRequest) XXX_DiscardUnknown()

func (*DispatcherCommandRequest) XXX_Marshal

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

func (*DispatcherCommandRequest) XXX_Merge

func (dst *DispatcherCommandRequest) XXX_Merge(src proto.Message)

func (*DispatcherCommandRequest) XXX_Size

func (m *DispatcherCommandRequest) XXX_Size() int

func (*DispatcherCommandRequest) XXX_Unmarshal

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

type DispatcherServiceClient

type DispatcherServiceClient interface {
	// handle a command
	HandleCommand(ctx context.Context, in *DispatcherCommandRequest, opts ...grpc.CallOption) (*DispatcherCommandReply, error)
}

DispatcherServiceClient is the client API for DispatcherService service.

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

func NewDispatcherServiceClient

func NewDispatcherServiceClient(cc *grpc.ClientConn) DispatcherServiceClient

type DispatcherServiceServer

type DispatcherServiceServer interface {
	// handle a command
	HandleCommand(context.Context, *DispatcherCommandRequest) (*DispatcherCommandReply, error)
}

DispatcherServiceServer is the server API for DispatcherService service.