grpc

Documentation

Index

• Variables
• type BatchMessageWrapper
• type SimpleMessageWrapper
• type StatusCode
  • func (s *StatusCode) ToError() error
  • func (s *StatusCode) ToJSONString() string

Variables

var (
	ENV              = "env"
	IDC              = "idc"
	SYS              = "sys"
	PID              = "pid"
	IP               = "ip"
	USERNAME         = "username"
	PASSWD           = "passwd"
	LANGUAGE         = "language"
	PROTOCOL_TYPE    = "protocoltype"
	PROTOCOL_VERSION = "protocolversion"
	PROTOCOL_DESC    = "protocoldesc"
	SEQ_NUM          = "seqnum"
	UNIQUE_ID        = "uniqueid"
	TTL              = "ttl"
	PRODUCERGROUP    = "producergroup"
	TAG              = "tag"
	CONTENT_TYPE     = "contenttype"
)

var (
	REQUEST_CODE = "code"
	Version      = "version"
)

protocol key

var (
	EVENTMESHCLUSTER = "eventmeshcluster"
	EVENTMESHIP      = "eventmeship"
	EVENTMESHENV     = "eventmeshenv"
	EVENTMESHIDC     = "eventmeshidc"
)

EventMeshInstanceKey

var (
	RANDOMNO  = "randomNo"
	TOPIC     = "topic"
	BIZSEQNO  = "bizseqno"
	UNIQUEID  = "uniqueId"
	CONTENT   = "content"
	EXTFIELDS = "extFields"
)

PushMessageRequestBody

var (
	SUCCESS                                     = &StatusCode{"0", "success"}
	OVERLOAD                                    = &StatusCode{"1", "eventMesh overload, try later, "}
	EVENTMESH_REQUESTCODE_INVALID               = &StatusCode{"2", "requestCode can't be null, or must be number, "}
	EVENTMESH_SEND_SYNC_MSG_ERR                 = &StatusCode{"3", "eventMesh send rr msg err, "}
	EVENTMESH_WAITING_RR_MSG_ERR                = &StatusCode{"4", "eventMesh waiting rr msg err, "}
	EVENTMESH_PROTOCOL_HEADER_ERR               = &StatusCode{"6", "eventMesh protocol[header] err, "}
	EVENTMESH_PROTOCOL_BODY_ERR                 = &StatusCode{"7", "eventMesh protocol[body] err, "}
	EVENTMESH_STOP                              = &StatusCode{"8", "eventMesh will stop or had stopped, "}
	EVENTMESH_REJECT_BY_PROCESSOR_ERROR         = &StatusCode{"9", "eventMesh reject by processor error, "}
	EVENTMESH_BATCH_PUBLISH_ERR                 = &StatusCode{"10", "eventMesh batch publish messages error, "}
	EVENTMESH_SEND_BATCHLOG_MSG_ERR             = &StatusCode{"17", "eventMesh send batchlog msg err, "}
	EVENTMESH_BATCH_SPEED_OVER_LIMIT_ERR        = &StatusCode{"11", "eventMesh batch msg speed over the limit, "}
	EVENTMESH_PACKAGE_MSG_ERR                   = &StatusCode{"12", "eventMesh package msg err, "}
	EVENTMESH_GROUP_PRODUCER_STOPED_ERR         = &StatusCode{"13", "eventMesh group producer stopped, "}
	EVENTMESH_SEND_ASYNC_MSG_ERR                = &StatusCode{"14", "eventMesh send async msg err, "}
	EVENTMESH_REPLY_MSG_ERR                     = &StatusCode{"15", "eventMesh reply msg err, "}
	EVENTMESH_RUNTIME_ERR                       = &StatusCode{"16", "eventMesh runtime err, "}
	EVENTMESH_SUBSCRIBE_ERR                     = &StatusCode{"17", "eventMesh subscribe err"}
	EVENTMESH_UNSUBSCRIBE_ERR                   = &StatusCode{"18", "eventMesh unsubscribe err"}
	EVENTMESH_HEARTBEAT_ERR                     = &StatusCode{"19", "eventMesh heartbeat err"}
	EVENTMESH_ACL_ERR                           = &StatusCode{"20", "eventMesh acl err"}
	EVENTMESH_SEND_MESSAGE_SPEED_OVER_LIMIT_ERR = &StatusCode{"21", "eventMesh send message speed over the limit err."}
	EVENTMESH_REQUEST_REPLY_MSG_ERR             = &StatusCode{"22", "eventMesh request reply msg err, "}
	EVENTMESH_Plugin_NotFound_ERR               = &StatusCode{"23", "eventMesh plugin not found err"}
	EVENTMESH_Transfer_Protocol_ERR             = &StatusCode{"24", "eventMesh plugin build event message err"}
	EVENTMESH_Producer_Group_NotFound_ERR       = &StatusCode{"25", "eventMesh producer not found err build event message err"}
	EVENTMESH_Subscribe_Register_ERR            = &StatusCode{"26", "eventMesh subscribe register err"}
	EVENTMESH_Consumer_NotFound_ERR             = &StatusCode{"27", "eventMesh consumer not found err build event message err"}
	EVENTMESH_Restart_Consumer_ERR              = &StatusCode{"28", "eventMesh restart consumer err"}
	EVENTMESH_Heartbeat_Protocol_ERR            = &StatusCode{"29", "eventMesh heartbeat but protocol not sub err"}
)

var (
	HTTP_PUSH_CLIENT_ASYNC = "105"
)

request code

Types

type BatchMessageWrapper

type BatchMessageWrapper struct {
	BatchMessage *pb.BatchMessage `json:"batchMessage"`
}

type SimpleMessageWrapper

type SimpleMessageWrapper struct {
	SimpleMessage *pb.SimpleMessage `json:"simpleMessage"`
}

type StatusCode

type StatusCode struct {
	RetCode string `json:"respCode"`
	ErrMsg  string `json:"respMsg"`
}

func (*StatusCode) ToError

func (s *StatusCode) ToError() error

func (*StatusCode) ToJSONString

func (s *StatusCode) ToJSONString() string