msg

package
v0.0.0-...-fabbfc5 Latest Latest
Warning

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

 Go to latest Published: Feb 2, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewMsgStreamEndpoints 

func NewMsgStreamEndpoints() []*api.Endpoint

func RegisterMsgStreamHandler 

func RegisterMsgStreamHandler(s server.Server, hdlr MsgStreamHandler, opts ...server.HandlerOption) error

Types

type Field 

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

func (*Field) Descriptor 

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

func (*Field) GetName 

func (m *Field) GetName() string

func (*Field) GetType 

func (m *Field) GetType() string

func (*Field) ProtoMessage 

func (*Field) ProtoMessage()

func (*Field) Reset 

func (m *Field) Reset()

func (*Field) String 

func (m *Field) String() string

func (*Field) XXX_DiscardUnknown 

func (m *Field) XXX_DiscardUnknown()

func (*Field) XXX_Marshal 

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

func (*Field) XXX_Merge 

func (m *Field) XXX_Merge(src proto.Message)

func (*Field) XXX_Size 

func (m *Field) XXX_Size() int

func (*Field) XXX_Unmarshal 

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

type HeartBeatRequest 

type HeartBeatRequest struct {
	AreYouOk             string   `protobuf:"bytes,1,opt,name=areYouOk,proto3" json:"areYouOk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HeartBeatRequest) Descriptor 

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

func (*HeartBeatRequest) GetAreYouOk 

func (m *HeartBeatRequest) GetAreYouOk() string

func (*HeartBeatRequest) ProtoMessage 

func (*HeartBeatRequest) ProtoMessage()

func (*HeartBeatRequest) Reset 

func (m *HeartBeatRequest) Reset()

func (*HeartBeatRequest) String 

func (m *HeartBeatRequest) String() string

func (*HeartBeatRequest) XXX_DiscardUnknown 

func (m *HeartBeatRequest) XXX_DiscardUnknown()

func (*HeartBeatRequest) XXX_Marshal 

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

func (*HeartBeatRequest) XXX_Merge 

func (m *HeartBeatRequest) XXX_Merge(src proto.Message)

func (*HeartBeatRequest) XXX_Size 

func (m *HeartBeatRequest) XXX_Size() int

func (*HeartBeatRequest) XXX_Unmarshal 

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

type HeartBeatRespond 

type HeartBeatRespond struct {
	ImOK                 string   `protobuf:"bytes,1,opt,name=imOK,proto3" json:"imOK,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HeartBeatRespond) Descriptor 

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

func (*HeartBeatRespond) GetImOK 

func (m *HeartBeatRespond) GetImOK() string

func (*HeartBeatRespond) ProtoMessage 

func (*HeartBeatRespond) ProtoMessage()

func (*HeartBeatRespond) Reset 

func (m *HeartBeatRespond) Reset()

func (*HeartBeatRespond) String 

func (m *HeartBeatRespond) String() string

func (*HeartBeatRespond) XXX_DiscardUnknown 

func (m *HeartBeatRespond) XXX_DiscardUnknown()

func (*HeartBeatRespond) XXX_Marshal 

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

func (*HeartBeatRespond) XXX_Merge 

func (m *HeartBeatRespond) XXX_Merge(src proto.Message)

func (*HeartBeatRespond) XXX_Size 

func (m *HeartBeatRespond) XXX_Size() int

func (*HeartBeatRespond) XXX_Unmarshal 

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

type MsgByte 

type MsgByte struct {
	Byte                 []byte   `protobuf:"bytes,1,opt,name=byte,proto3" json:"byte,omitempty"`
	Len                  int64    `protobuf:"varint,2,opt,name=len,proto3" json:"len,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MsgByte) Descriptor 

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

func (*MsgByte) GetByte 

func (m *MsgByte) GetByte() []byte

func (*MsgByte) GetLen 

func (m *MsgByte) GetLen() int64

func (*MsgByte) ProtoMessage 

func (*MsgByte) ProtoMessage()

func (*MsgByte) Reset 

func (m *MsgByte) Reset()

func (*MsgByte) String 

func (m *MsgByte) String() string

func (*MsgByte) XXX_DiscardUnknown 

func (m *MsgByte) XXX_DiscardUnknown()

func (*MsgByte) XXX_Marshal 

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

func (*MsgByte) XXX_Merge 

func (m *MsgByte) XXX_Merge(src proto.Message)

func (*MsgByte) XXX_Size 

func (m *MsgByte) XXX_Size() int

func (*MsgByte) XXX_Unmarshal 

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

type MsgStreamHandler 

type MsgStreamHandler interface {
	Msg(context.Context, MsgStream_MsgStream) error
	HeartBeat(context.Context, *HeartBeatRequest, *HeartBeatRespond) error
}

type MsgStreamService 

type MsgStreamService interface {
	Msg(ctx context.Context, opts ...client.CallOption) (MsgStream_MsgService, error)
	HeartBeat(ctx context.Context, in *HeartBeatRequest, opts ...client.CallOption) (*HeartBeatRespond, error)
}

func NewMsgStreamService 

func NewMsgStreamService(name string, c client.Client) MsgStreamService

type MsgStream_MsgService 

type MsgStream_MsgService interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*StreamMessage) error
}

type MsgStream_MsgStream 

type MsgStream_MsgStream interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*StreamMessage, error)
}

type Payload 

type Payload struct {
	Value                []string `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Payload) Descriptor 

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

func (*Payload) GetValue 

func (m *Payload) GetValue() []string

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) Reset 

func (m *Payload) Reset()

func (*Payload) String 

func (m *Payload) String() string

func (*Payload) XXX_DiscardUnknown 

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal 

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

func (*Payload) XXX_Merge 

func (m *Payload) XXX_Merge(src proto.Message)

func (*Payload) XXX_Size 

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal 

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

type StreamMessage 

type StreamMessage struct {
	Namespace            string            `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Id                   string            `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Fields               []*Field          `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"`
	Payload              []*Payload        `protobuf:"bytes,4,rep,name=payload,proto3" json:"payload,omitempty"`
	Extends              map[string]string `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*StreamMessage) Descriptor 

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

func (*StreamMessage) GetExtends 

func (m *StreamMessage) GetExtends() map[string]string

func (*StreamMessage) GetFields 

func (m *StreamMessage) GetFields() []*Field

func (*StreamMessage) GetId 

func (m *StreamMessage) GetId() string

func (*StreamMessage) GetNamespace 

func (m *StreamMessage) GetNamespace() string

func (*StreamMessage) GetPayload 

func (m *StreamMessage) GetPayload() []*Payload

func (*StreamMessage) ProtoMessage 

func (*StreamMessage) ProtoMessage()

func (*StreamMessage) Reset 

func (m *StreamMessage) Reset()

func (*StreamMessage) String 

func (m *StreamMessage) String() string

func (*StreamMessage) XXX_DiscardUnknown 

func (m *StreamMessage) XXX_DiscardUnknown()

func (*StreamMessage) XXX_Marshal 

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

func (*StreamMessage) XXX_Merge 

func (m *StreamMessage) XXX_Merge(src proto.Message)

func (*StreamMessage) XXX_Size 

func (m *StreamMessage) XXX_Size() int

func (*StreamMessage) XXX_Unmarshal 

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

type StreamResponse 

type StreamResponse struct {
	Status               string   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamResponse) Descriptor 

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

func (*StreamResponse) GetStatus 

func (m *StreamResponse) GetStatus() string

func (*StreamResponse) ProtoMessage 

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) Reset 

func (m *StreamResponse) Reset()

func (*StreamResponse) String 

func (m *StreamResponse) String() string

func (*StreamResponse) XXX_DiscardUnknown 

func (m *StreamResponse) XXX_DiscardUnknown()

func (*StreamResponse) XXX_Marshal 

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

func (*StreamResponse) XXX_Merge 

func (m *StreamResponse) XXX_Merge(src proto.Message)

func (*StreamResponse) XXX_Size 

func (m *StreamResponse) XXX_Size() int

func (*StreamResponse) XXX_Unmarshal 

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

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.