schema

package
v0.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 10, 2019 License: GPL-3.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthEventmsg = fmt.Errorf("protobuf: negative length found during unmarshaling")
	ErrIntOverflowEventmsg   = fmt.Errorf("protobuf: integer overflow")
)
View Source 
var ReqQ_MsgComType_name = map[int32]string{
	0: "QUE",
	1: "SUB",
}
View Source 
var ReqQ_MsgComType_value = map[string]int32{
	"QUE": 0,
	"SUB": 1,
}
View Source 
var ResEvent_ResultType_name = map[int32]string{
	0: "SUCCESS",
	1: "FAILURE",
}
View Source 
var ResEvent_ResultType_value = map[string]int32{
	"SUCCESS": 0,
	"FAILURE": 1,
}

Functions

This section is empty.

Types

type CodeError 

type CodeError struct {
	Msg                  string   `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	Code                 string   `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
	Prefix               string   `protobuf:"bytes,3,opt,name=prefix,proto3" json:"prefix,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CodeError) Descriptor 

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

func (*CodeError) GetCode 

func (m *CodeError) GetCode() string

func (*CodeError) GetMsg 

func (m *CodeError) GetMsg() string

func (*CodeError) GetPrefix 

func (m *CodeError) GetPrefix() string

func (*CodeError) Marshal 

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

func (*CodeError) MarshalTo 

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

func (*CodeError) ProtoMessage 

func (*CodeError) ProtoMessage()

func (*CodeError) Reset 

func (m *CodeError) Reset()

func (*CodeError) Size 

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

func (*CodeError) String 

func (m *CodeError) String() string

func (*CodeError) Unmarshal 

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

func (*CodeError) XXX_DiscardUnknown 

func (m *CodeError) XXX_DiscardUnknown()

func (*CodeError) XXX_Marshal 

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

func (*CodeError) XXX_Merge 

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

func (*CodeError) XXX_Size 

func (m *CodeError) XXX_Size() int

func (*CodeError) XXX_Unmarshal 

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

type ReqEvent 

type ReqEvent struct {
	ReqId                int64    `protobuf:"varint,1,opt,name=reqId,proto3" json:"reqId,omitempty"`
	Name                 string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	MsgBody              []byte   `protobuf:"bytes,3,opt,name=msgBody,proto3" json:"msgBody,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReqEvent) Descriptor 

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

func (*ReqEvent) GetMsgBody 

func (m *ReqEvent) GetMsgBody() []byte

func (*ReqEvent) GetName 

func (m *ReqEvent) GetName() string

func (*ReqEvent) GetReqId 

func (m *ReqEvent) GetReqId() int64

func (*ReqEvent) Marshal 

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

func (*ReqEvent) MarshalTo 

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

func (*ReqEvent) ProtoMessage 

func (*ReqEvent) ProtoMessage()

func (*ReqEvent) Reset 

func (m *ReqEvent) Reset()

func (*ReqEvent) Size 

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

func (*ReqEvent) String 

func (m *ReqEvent) String() string

func (*ReqEvent) Unmarshal 

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

func (*ReqEvent) XXX_DiscardUnknown 

func (m *ReqEvent) XXX_DiscardUnknown()

func (*ReqEvent) XXX_Marshal 

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

func (*ReqEvent) XXX_Merge 

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

func (*ReqEvent) XXX_Size 

func (m *ReqEvent) XXX_Size() int

func (*ReqEvent) XXX_Unmarshal 

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

type ReqQ 

type ReqQ struct {
	ReqId                int64           `protobuf:"varint,1,opt,name=reqId,proto3" json:"reqId,omitempty"`
	Name                 string          `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	ComType              ReqQ_MsgComType `protobuf:"varint,3,opt,name=comType,proto3,enum=schema.ReqQ_MsgComType" json:"comType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

ReqQ message in queue

func (*ReqQ) Descriptor 

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

func (*ReqQ) GetComType 

func (m *ReqQ) GetComType() ReqQ_MsgComType

func (*ReqQ) GetName 

func (m *ReqQ) GetName() string

func (*ReqQ) GetReqId 

func (m *ReqQ) GetReqId() int64

func (*ReqQ) Marshal 

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

func (*ReqQ) MarshalTo 

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

func (*ReqQ) ProtoMessage 

func (*ReqQ) ProtoMessage()

func (*ReqQ) Reset 

func (m *ReqQ) Reset()

func (*ReqQ) Size 

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

func (*ReqQ) String 

func (m *ReqQ) String() string

func (*ReqQ) Unmarshal 

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

func (*ReqQ) XXX_DiscardUnknown 

func (m *ReqQ) XXX_DiscardUnknown()

func (*ReqQ) XXX_Marshal 

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

func (*ReqQ) XXX_Merge 

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

func (*ReqQ) XXX_Size 

func (m *ReqQ) XXX_Size() int

func (*ReqQ) XXX_Unmarshal 

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

type ReqQ_MsgComType 

type ReqQ_MsgComType int32
const (
	ReqQ_QUE ReqQ_MsgComType = 0
	ReqQ_SUB ReqQ_MsgComType = 1
)

func (ReqQ_MsgComType) EnumDescriptor 

func (ReqQ_MsgComType) EnumDescriptor() ([]byte, []int)

func (ReqQ_MsgComType) String 

func (x ReqQ_MsgComType) String() string

type ResEvent 

type ResEvent struct {
	ReqId                int64               `protobuf:"varint,1,opt,name=reqId,proto3" json:"reqId,omitempty"`
	Name                 string              `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	ResultType           ResEvent_ResultType `protobuf:"varint,3,opt,name=resultType,proto3,enum=schema.ResEvent_ResultType" json:"resultType,omitempty"`
	ResultBody           []byte              `protobuf:"bytes,5,opt,name=resultBody,proto3" json:"resultBody,omitempty"`
	Error                *CodeError          `protobuf:"bytes,4,opt,name=error" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ResEvent) Descriptor 

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

func (*ResEvent) GetError 

func (m *ResEvent) GetError() *CodeError

func (*ResEvent) GetName 

func (m *ResEvent) GetName() string

func (*ResEvent) GetReqId 

func (m *ResEvent) GetReqId() int64

func (*ResEvent) GetResultBody 

func (m *ResEvent) GetResultBody() []byte

func (*ResEvent) GetResultType 

func (m *ResEvent) GetResultType() ResEvent_ResultType

func (*ResEvent) Marshal 

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

func (*ResEvent) MarshalTo 

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

func (*ResEvent) ProtoMessage 

func (*ResEvent) ProtoMessage()

func (*ResEvent) Reset 

func (m *ResEvent) Reset()

func (*ResEvent) Size 

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

func (*ResEvent) String 

func (m *ResEvent) String() string

func (*ResEvent) Unmarshal 

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

func (*ResEvent) XXX_DiscardUnknown 

func (m *ResEvent) XXX_DiscardUnknown()

func (*ResEvent) XXX_Marshal 

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

func (*ResEvent) XXX_Merge 

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

func (*ResEvent) XXX_Size 

func (m *ResEvent) XXX_Size() int

func (*ResEvent) XXX_Unmarshal 

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

type ResEvent_ResultType 

type ResEvent_ResultType int32
const (
	ResEvent_SUCCESS ResEvent_ResultType = 0
	ResEvent_FAILURE ResEvent_ResultType = 1
)

func (ResEvent_ResultType) EnumDescriptor 

func (ResEvent_ResultType) EnumDescriptor() ([]byte, []int)

func (ResEvent_ResultType) String 

func (x ResEvent_ResultType) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.