Documentation ¶
Index ¶
- Variables
- type LogMessage
- func (*LogMessage) Descriptor() ([]byte, []int)
- func (m *LogMessage) GetContent() []byte
- func (m *LogMessage) GetDestination() string
- func (m *LogMessage) GetSender() string
- func (*LogMessage) ProtoMessage()
- func (m *LogMessage) Reset()
- func (m *LogMessage) String() string
- func (m *LogMessage) XXX_DiscardUnknown()
- func (m *LogMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LogMessage) XXX_Merge(src proto.Message)
- func (m *LogMessage) XXX_Size() int
- func (m *LogMessage) XXX_Unmarshal(b []byte) error
- type Message
- func (*Message) Descriptor() ([]byte, []int)
- func (m *Message) GetContent() []byte
- func (m *Message) GetType() Message_MessageType
- func (*Message) ProtoMessage()
- func (m *Message) Reset()
- func (m *Message) String() string
- func (m *Message) XXX_DiscardUnknown()
- func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Message) XXX_Merge(src proto.Message)
- func (m *Message) XXX_Size() int
- func (m *Message) XXX_Unmarshal(b []byte) error
- type Message_MessageType
- type Publish
- func (*Publish) Descriptor() ([]byte, []int)
- func (m *Publish) GetData() []byte
- func (m *Publish) GetEvent() string
- func (*Publish) ProtoMessage()
- func (m *Publish) Reset()
- func (m *Publish) String() string
- func (m *Publish) XXX_DiscardUnknown()
- func (m *Publish) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Publish) XXX_Merge(src proto.Message)
- func (m *Publish) XXX_Size() int
- func (m *Publish) XXX_Unmarshal(b []byte) error
- type Register
- func (*Register) Descriptor() ([]byte, []int)
- func (m *Register) GetIdentification() string
- func (m *Register) GetName() string
- func (*Register) ProtoMessage()
- func (m *Register) Reset()
- func (m *Register) String() string
- func (m *Register) XXX_DiscardUnknown()
- func (m *Register) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Register) XXX_Merge(src proto.Message)
- func (m *Register) XXX_Size() int
- func (m *Register) XXX_Unmarshal(b []byte) error
- type Reply
- func (*Reply) Descriptor() ([]byte, []int)
- func (m *Reply) GetData() []byte
- func (m *Reply) GetError() *Reply_Error
- func (m *Reply) GetId() uint64
- func (*Reply) ProtoMessage()
- func (m *Reply) Reset()
- func (m *Reply) String() string
- func (m *Reply) XXX_DiscardUnknown()
- func (m *Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Reply) XXX_Merge(src proto.Message)
- func (m *Reply) XXX_Size() int
- func (m *Reply) XXX_Unmarshal(b []byte) error
- type Reply_Error
- func (*Reply_Error) Descriptor() ([]byte, []int)
- func (m *Reply_Error) GetType() Reply_Error_Type
- func (m *Reply_Error) GetWhat() string
- func (*Reply_Error) ProtoMessage()
- func (m *Reply_Error) Reset()
- func (m *Reply_Error) String() string
- func (m *Reply_Error) XXX_DiscardUnknown()
- func (m *Reply_Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Reply_Error) XXX_Merge(src proto.Message)
- func (m *Reply_Error) XXX_Size() int
- func (m *Reply_Error) XXX_Unmarshal(b []byte) error
- type Reply_Error_Type
- type Request
- func (*Request) Descriptor() ([]byte, []int)
- func (m *Request) GetData() []byte
- func (m *Request) GetId() uint64
- func (m *Request) GetMethod() string
- func (m *Request) GetServiceIdentification() string
- func (m *Request) GetServiceName() string
- func (*Request) ProtoMessage()
- func (m *Request) Reset()
- func (m *Request) String() string
- func (m *Request) XXX_DiscardUnknown()
- func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Request) XXX_Merge(src proto.Message)
- func (m *Request) XXX_Size() int
- func (m *Request) XXX_Unmarshal(b []byte) error
- type Subscribe
- func (*Subscribe) Descriptor() ([]byte, []int)
- func (m *Subscribe) GetEvent() string
- func (*Subscribe) ProtoMessage()
- func (m *Subscribe) Reset()
- func (m *Subscribe) String() string
- func (m *Subscribe) XXX_DiscardUnknown()
- func (m *Subscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Subscribe) XXX_Merge(src proto.Message)
- func (m *Subscribe) XXX_Size() int
- func (m *Subscribe) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var Message_MessageType_name = map[int32]string{
0: "Register",
1: "Request",
2: "Reply",
3: "Subscribe",
4: "Publish",
}
View Source
var Message_MessageType_value = map[string]int32{
"Register": 0,
"Request": 1,
"Reply": 2,
"Subscribe": 3,
"Publish": 4,
}
View Source
var Reply_Error_Type_name = map[int32]string{
0: "NoError",
1: "NoSuchService",
2: "InvalidIdentification",
3: "NoSuchMethod",
4: "BadArguments",
5: "Timeout",
126: "Custom",
}
View Source
var Reply_Error_Type_value = map[string]int32{
"NoError": 0,
"NoSuchService": 1,
"InvalidIdentification": 2,
"NoSuchMethod": 3,
"BadArguments": 4,
"Timeout": 5,
"Custom": 126,
}
Functions ¶
This section is empty.
Types ¶
type LogMessage ¶
type LogMessage struct { Sender *string `protobuf:"bytes,1,req,name=sender" json:"sender,omitempty"` Destination *string `protobuf:"bytes,3,opt,name=destination" json:"destination,omitempty"` Content []byte `protobuf:"bytes,2,req,name=content" json:"content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogMessage) Descriptor ¶
func (*LogMessage) Descriptor() ([]byte, []int)
func (*LogMessage) GetContent ¶
func (m *LogMessage) GetContent() []byte
func (*LogMessage) GetDestination ¶
func (m *LogMessage) GetDestination() string
func (*LogMessage) GetSender ¶
func (m *LogMessage) GetSender() string
func (*LogMessage) ProtoMessage ¶
func (*LogMessage) ProtoMessage()
func (*LogMessage) Reset ¶
func (m *LogMessage) Reset()
func (*LogMessage) String ¶
func (m *LogMessage) String() string
func (*LogMessage) XXX_DiscardUnknown ¶
func (m *LogMessage) XXX_DiscardUnknown()
func (*LogMessage) XXX_Marshal ¶
func (m *LogMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogMessage) XXX_Merge ¶
func (m *LogMessage) XXX_Merge(src proto.Message)
func (*LogMessage) XXX_Size ¶
func (m *LogMessage) XXX_Size() int
func (*LogMessage) XXX_Unmarshal ¶
func (m *LogMessage) XXX_Unmarshal(b []byte) error
type Message ¶
type Message struct { Type Message_MessageType `protobuf:"varint,1,opt,name=type,proto3,enum=cellaserv.Message_MessageType" json:"type,omitempty"` // This field contains the serialized, actual message: Register, Request... Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Message) Descriptor ¶
func (*Message) GetContent ¶
func (*Message) GetType ¶
func (m *Message) GetType() Message_MessageType
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) XXX_DiscardUnknown ¶
func (m *Message) XXX_DiscardUnknown()
func (*Message) XXX_Marshal ¶
func (*Message) XXX_Unmarshal ¶
type Message_MessageType ¶
type Message_MessageType int32
const ( Message_Register Message_MessageType = 0 Message_Request Message_MessageType = 1 Message_Reply Message_MessageType = 2 Message_Subscribe Message_MessageType = 3 Message_Publish Message_MessageType = 4 )
func (Message_MessageType) EnumDescriptor ¶
func (Message_MessageType) EnumDescriptor() ([]byte, []int)
func (Message_MessageType) String ¶
func (x Message_MessageType) String() string
type Publish ¶
type Publish struct { // The name of the event the sender is publishing Event string `protobuf:"bytes,1,opt,name=event,proto3" json:"event,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 (*Publish) Descriptor ¶
func (*Publish) ProtoMessage ¶
func (*Publish) ProtoMessage()
func (*Publish) XXX_DiscardUnknown ¶
func (m *Publish) XXX_DiscardUnknown()
func (*Publish) XXX_Marshal ¶
func (*Publish) XXX_Unmarshal ¶
type Register ¶
type Register struct { // Name of the service Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // Use this field if multiple instances of the service exist Identification string `protobuf:"bytes,2,opt,name=identification,proto3" json:"identification,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Register) Descriptor ¶
func (*Register) GetIdentification ¶
func (*Register) ProtoMessage ¶
func (*Register) ProtoMessage()
func (*Register) XXX_DiscardUnknown ¶
func (m *Register) XXX_DiscardUnknown()
func (*Register) XXX_Marshal ¶
func (*Register) XXX_Unmarshal ¶
type Reply ¶
type Reply struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` Error *Reply_Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` Id uint64 `protobuf:"fixed64,99,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Reply) Descriptor ¶
func (*Reply) GetError ¶
func (m *Reply) GetError() *Reply_Error
func (*Reply) ProtoMessage ¶
func (*Reply) ProtoMessage()
func (*Reply) XXX_DiscardUnknown ¶
func (m *Reply) XXX_DiscardUnknown()
func (*Reply) XXX_Marshal ¶
func (*Reply) XXX_Unmarshal ¶
type Reply_Error ¶
type Reply_Error struct { Type Reply_Error_Type `protobuf:"varint,1,opt,name=type,proto3,enum=cellaserv.Reply_Error_Type" json:"type,omitempty"` What string `protobuf:"bytes,2,opt,name=what,proto3" json:"what,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Reply_Error) Descriptor ¶
func (*Reply_Error) Descriptor() ([]byte, []int)
func (*Reply_Error) GetType ¶
func (m *Reply_Error) GetType() Reply_Error_Type
func (*Reply_Error) GetWhat ¶
func (m *Reply_Error) GetWhat() string
func (*Reply_Error) ProtoMessage ¶
func (*Reply_Error) ProtoMessage()
func (*Reply_Error) Reset ¶
func (m *Reply_Error) Reset()
func (*Reply_Error) String ¶
func (m *Reply_Error) String() string
func (*Reply_Error) XXX_DiscardUnknown ¶
func (m *Reply_Error) XXX_DiscardUnknown()
func (*Reply_Error) XXX_Marshal ¶
func (m *Reply_Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Reply_Error) XXX_Merge ¶
func (m *Reply_Error) XXX_Merge(src proto.Message)
func (*Reply_Error) XXX_Size ¶
func (m *Reply_Error) XXX_Size() int
func (*Reply_Error) XXX_Unmarshal ¶
func (m *Reply_Error) XXX_Unmarshal(b []byte) error
type Reply_Error_Type ¶
type Reply_Error_Type int32
const ( Reply_Error_NoError Reply_Error_Type = 0 Reply_Error_NoSuchService Reply_Error_Type = 1 Reply_Error_InvalidIdentification Reply_Error_Type = 2 Reply_Error_NoSuchMethod Reply_Error_Type = 3 Reply_Error_BadArguments Reply_Error_Type = 4 Reply_Error_Timeout Reply_Error_Type = 5 // If you use this error type you should explain the error in the // 'what' field Reply_Error_Custom Reply_Error_Type = 126 )
func (Reply_Error_Type) EnumDescriptor ¶
func (Reply_Error_Type) EnumDescriptor() ([]byte, []int)
func (Reply_Error_Type) String ¶
func (x Reply_Error_Type) String() string
type Request ¶
type Request struct { ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` ServiceIdentification string `protobuf:"bytes,2,opt,name=service_identification,json=serviceIdentification,proto3" json:"service_identification,omitempty"` Method string `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"` Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` Id uint64 `protobuf:"fixed64,99,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Request) Descriptor ¶
func (*Request) GetServiceIdentification ¶
func (*Request) GetServiceName ¶
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) XXX_DiscardUnknown ¶
func (m *Request) XXX_DiscardUnknown()
func (*Request) XXX_Marshal ¶
func (*Request) XXX_Unmarshal ¶
type Subscribe ¶
type Subscribe struct { // The name of the event the sender of this message is subscribing to Event string `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Subscribe) Descriptor ¶
func (*Subscribe) ProtoMessage ¶
func (*Subscribe) ProtoMessage()
func (*Subscribe) XXX_DiscardUnknown ¶
func (m *Subscribe) XXX_DiscardUnknown()
func (*Subscribe) XXX_Marshal ¶
func (*Subscribe) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.