types

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Dec 9, 2019 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Request 

type Request struct {
	// Types that are valid to be assigned to Value:
	//	*Request_Send
	//	*Request_Fetch
	//	*Request_Clients
	//	*Request_Details
	//	*Request_Flush
	Value                isRequest_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Request) Descriptor 

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

func (*Request) GetClients 

func (m *Request) GetClients() *RequestGetClients

func (*Request) GetDetails 

func (m *Request) GetDetails() *RequestOwnDetails

func (*Request) GetFetch 

func (m *Request) GetFetch() *RequestFetchMessages

func (*Request) GetFlush 

func (m *Request) GetFlush() *RequestFlush

func (*Request) GetSend 

func (m *Request) GetSend() *RequestSendMessage

func (*Request) GetValue 

func (m *Request) GetValue() isRequest_Value

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) String 

func (m *Request) String() string

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_OneofWrappers 

func (*Request) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type RequestFetchMessages 

type RequestFetchMessages struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestFetchMessages) Descriptor 

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

func (*RequestFetchMessages) ProtoMessage 

func (*RequestFetchMessages) ProtoMessage()

func (*RequestFetchMessages) Reset 

func (m *RequestFetchMessages) Reset()

func (*RequestFetchMessages) String 

func (m *RequestFetchMessages) String() string

func (*RequestFetchMessages) XXX_DiscardUnknown 

func (m *RequestFetchMessages) XXX_DiscardUnknown()

func (*RequestFetchMessages) XXX_Marshal 

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

func (*RequestFetchMessages) XXX_Merge 

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

func (*RequestFetchMessages) XXX_Size 

func (m *RequestFetchMessages) XXX_Size() int

func (*RequestFetchMessages) XXX_Unmarshal 

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

type RequestFlush 

type RequestFlush struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestFlush) Descriptor 

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

func (*RequestFlush) ProtoMessage 

func (*RequestFlush) ProtoMessage()

func (*RequestFlush) Reset 

func (m *RequestFlush) Reset()

func (*RequestFlush) String 

func (m *RequestFlush) String() string

func (*RequestFlush) XXX_DiscardUnknown 

func (m *RequestFlush) XXX_DiscardUnknown()

func (*RequestFlush) XXX_Marshal 

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

func (*RequestFlush) XXX_Merge 

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

func (*RequestFlush) XXX_Size 

func (m *RequestFlush) XXX_Size() int

func (*RequestFlush) XXX_Unmarshal 

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

type RequestGetClients 

type RequestGetClients struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestGetClients) Descriptor 

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

func (*RequestGetClients) ProtoMessage 

func (*RequestGetClients) ProtoMessage()

func (*RequestGetClients) Reset 

func (m *RequestGetClients) Reset()

func (*RequestGetClients) String 

func (m *RequestGetClients) String() string

func (*RequestGetClients) XXX_DiscardUnknown 

func (m *RequestGetClients) XXX_DiscardUnknown()

func (*RequestGetClients) XXX_Marshal 

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

func (*RequestGetClients) XXX_Merge 

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

func (*RequestGetClients) XXX_Size 

func (m *RequestGetClients) XXX_Size() int

func (*RequestGetClients) XXX_Unmarshal 

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

type RequestOwnDetails 

type RequestOwnDetails struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestOwnDetails) Descriptor 

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

func (*RequestOwnDetails) ProtoMessage 

func (*RequestOwnDetails) ProtoMessage()

func (*RequestOwnDetails) Reset 

func (m *RequestOwnDetails) Reset()

func (*RequestOwnDetails) String 

func (m *RequestOwnDetails) String() string

func (*RequestOwnDetails) XXX_DiscardUnknown 

func (m *RequestOwnDetails) XXX_DiscardUnknown()

func (*RequestOwnDetails) XXX_Marshal 

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

func (*RequestOwnDetails) XXX_Merge 

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

func (*RequestOwnDetails) XXX_Size 

func (m *RequestOwnDetails) XXX_Size() int

func (*RequestOwnDetails) XXX_Unmarshal 

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

type RequestSendMessage 

type RequestSendMessage struct {
	Message              []byte               `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Recipient            *config.ClientConfig `protobuf:"bytes,2,opt,name=recipient,proto3" json:"recipient,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*RequestSendMessage) Descriptor 

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

func (*RequestSendMessage) GetMessage 

func (m *RequestSendMessage) GetMessage() []byte

func (*RequestSendMessage) GetRecipient 

func (m *RequestSendMessage) GetRecipient() *config.ClientConfig

func (*RequestSendMessage) ProtoMessage 

func (*RequestSendMessage) ProtoMessage()

func (*RequestSendMessage) Reset 

func (m *RequestSendMessage) Reset()

func (*RequestSendMessage) String 

func (m *RequestSendMessage) String() string

func (*RequestSendMessage) XXX_DiscardUnknown 

func (m *RequestSendMessage) XXX_DiscardUnknown()

func (*RequestSendMessage) XXX_Marshal 

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

func (*RequestSendMessage) XXX_Merge 

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

func (*RequestSendMessage) XXX_Size 

func (m *RequestSendMessage) XXX_Size() int

func (*RequestSendMessage) XXX_Unmarshal 

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

type Request_Clients 

type Request_Clients struct {
	Clients *RequestGetClients `protobuf:"bytes,4,opt,name=clients,proto3,oneof"`
}

type Request_Details 

type Request_Details struct {
	Details *RequestOwnDetails `protobuf:"bytes,5,opt,name=details,proto3,oneof"`
}

type Request_Fetch 

type Request_Fetch struct {
	Fetch *RequestFetchMessages `protobuf:"bytes,3,opt,name=fetch,proto3,oneof"`
}

type Request_Flush 

type Request_Flush struct {
	Flush *RequestFlush `protobuf:"bytes,6,opt,name=flush,proto3,oneof"`
}

type Request_Send 

type Request_Send struct {
	Send *RequestSendMessage `protobuf:"bytes,2,opt,name=send,proto3,oneof"`
}

type Response 

type Response struct {
	// Types that are valid to be assigned to Value:
	//	*Response_Exception
	//	*Response_Send
	//	*Response_Fetch
	//	*Response_Clients
	//	*Response_Details
	//	*Response_Flush
	Value                isResponse_Value `protobuf_oneof:"value"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Response) Descriptor 

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

func (*Response) GetClients 

func (m *Response) GetClients() *ResponseGetClients

func (*Response) GetDetails 

func (m *Response) GetDetails() *ResponseOwnDetails

func (*Response) GetException 

func (m *Response) GetException() *ResponseException

func (*Response) GetFetch 

func (m *Response) GetFetch() *ResponseFetchMessages

func (*Response) GetFlush 

func (m *Response) GetFlush() *ResponseFlush

func (*Response) GetSend 

func (m *Response) GetSend() *ResponseSendMessage

func (*Response) GetValue 

func (m *Response) GetValue() isResponse_Value

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_OneofWrappers 

func (*Response) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type ResponseException 

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

func (*ResponseException) Descriptor 

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

func (*ResponseException) GetError 

func (m *ResponseException) GetError() string

func (*ResponseException) ProtoMessage 

func (*ResponseException) ProtoMessage()

func (*ResponseException) Reset 

func (m *ResponseException) Reset()

func (*ResponseException) String 

func (m *ResponseException) String() string

func (*ResponseException) XXX_DiscardUnknown 

func (m *ResponseException) XXX_DiscardUnknown()

func (*ResponseException) XXX_Marshal 

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

func (*ResponseException) XXX_Merge 

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

func (*ResponseException) XXX_Size 

func (m *ResponseException) XXX_Size() int

func (*ResponseException) XXX_Unmarshal 

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

type ResponseFetchMessages 

type ResponseFetchMessages struct {
	Messages             [][]byte `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResponseFetchMessages) Descriptor 

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

func (*ResponseFetchMessages) GetMessages 

func (m *ResponseFetchMessages) GetMessages() [][]byte

func (*ResponseFetchMessages) ProtoMessage 

func (*ResponseFetchMessages) ProtoMessage()

func (*ResponseFetchMessages) Reset 

func (m *ResponseFetchMessages) Reset()

func (*ResponseFetchMessages) String 

func (m *ResponseFetchMessages) String() string

func (*ResponseFetchMessages) XXX_DiscardUnknown 

func (m *ResponseFetchMessages) XXX_DiscardUnknown()

func (*ResponseFetchMessages) XXX_Marshal 

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

func (*ResponseFetchMessages) XXX_Merge 

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

func (*ResponseFetchMessages) XXX_Size 

func (m *ResponseFetchMessages) XXX_Size() int

func (*ResponseFetchMessages) XXX_Unmarshal 

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

type ResponseFlush 

type ResponseFlush struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResponseFlush) Descriptor 

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

func (*ResponseFlush) ProtoMessage 

func (*ResponseFlush) ProtoMessage()

func (*ResponseFlush) Reset 

func (m *ResponseFlush) Reset()

func (*ResponseFlush) String 

func (m *ResponseFlush) String() string

func (*ResponseFlush) XXX_DiscardUnknown 

func (m *ResponseFlush) XXX_DiscardUnknown()

func (*ResponseFlush) XXX_Marshal 

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

func (*ResponseFlush) XXX_Merge 

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

func (*ResponseFlush) XXX_Size 

func (m *ResponseFlush) XXX_Size() int

func (*ResponseFlush) XXX_Unmarshal 

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

type ResponseGetClients 

type ResponseGetClients struct {
	Clients              []*config.ClientConfig `protobuf:"bytes,1,rep,name=clients,proto3" json:"clients,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*ResponseGetClients) Descriptor 

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

func (*ResponseGetClients) GetClients 

func (m *ResponseGetClients) GetClients() []*config.ClientConfig

func (*ResponseGetClients) ProtoMessage 

func (*ResponseGetClients) ProtoMessage()

func (*ResponseGetClients) Reset 

func (m *ResponseGetClients) Reset()

func (*ResponseGetClients) String 

func (m *ResponseGetClients) String() string

func (*ResponseGetClients) XXX_DiscardUnknown 

func (m *ResponseGetClients) XXX_DiscardUnknown()

func (*ResponseGetClients) XXX_Marshal 

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

func (*ResponseGetClients) XXX_Merge 

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

func (*ResponseGetClients) XXX_Size 

func (m *ResponseGetClients) XXX_Size() int

func (*ResponseGetClients) XXX_Unmarshal 

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

type ResponseOwnDetails 

type ResponseOwnDetails struct {
	Details              *config.ClientConfig `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*ResponseOwnDetails) Descriptor 

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

func (*ResponseOwnDetails) GetDetails 

func (m *ResponseOwnDetails) GetDetails() *config.ClientConfig

func (*ResponseOwnDetails) ProtoMessage 

func (*ResponseOwnDetails) ProtoMessage()

func (*ResponseOwnDetails) Reset 

func (m *ResponseOwnDetails) Reset()

func (*ResponseOwnDetails) String 

func (m *ResponseOwnDetails) String() string

func (*ResponseOwnDetails) XXX_DiscardUnknown 

func (m *ResponseOwnDetails) XXX_DiscardUnknown()

func (*ResponseOwnDetails) XXX_Marshal 

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

func (*ResponseOwnDetails) XXX_Merge 

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

func (*ResponseOwnDetails) XXX_Size 

func (m *ResponseOwnDetails) XXX_Size() int

func (*ResponseOwnDetails) XXX_Unmarshal 

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

type ResponseSendMessage 

type ResponseSendMessage struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResponseSendMessage) Descriptor 

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

func (*ResponseSendMessage) ProtoMessage 

func (*ResponseSendMessage) ProtoMessage()

func (*ResponseSendMessage) Reset 

func (m *ResponseSendMessage) Reset()

func (*ResponseSendMessage) String 

func (m *ResponseSendMessage) String() string

func (*ResponseSendMessage) XXX_DiscardUnknown 

func (m *ResponseSendMessage) XXX_DiscardUnknown()

func (*ResponseSendMessage) XXX_Marshal 

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

func (*ResponseSendMessage) XXX_Merge 

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

func (*ResponseSendMessage) XXX_Size 

func (m *ResponseSendMessage) XXX_Size() int

func (*ResponseSendMessage) XXX_Unmarshal 

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

type Response_Clients 

type Response_Clients struct {
	Clients *ResponseGetClients `protobuf:"bytes,4,opt,name=clients,proto3,oneof"`
}

type Response_Details 

type Response_Details struct {
	Details *ResponseOwnDetails `protobuf:"bytes,5,opt,name=details,proto3,oneof"`
}

type Response_Exception 

type Response_Exception struct {
	Exception *ResponseException `protobuf:"bytes,1,opt,name=exception,proto3,oneof"`
}

type Response_Fetch 

type Response_Fetch struct {
	Fetch *ResponseFetchMessages `protobuf:"bytes,3,opt,name=fetch,proto3,oneof"`
}

type Response_Flush 

type Response_Flush struct {
	Flush *ResponseFlush `protobuf:"bytes,6,opt,name=flush,proto3,oneof"`
}

type Response_Send 

type Response_Send struct {
	Send *ResponseSendMessage `protobuf:"bytes,2,opt,name=send,proto3,oneof"`
}

type SocketListener 

type SocketListener interface {
	Start() error
	Shutdown()
	Wait()
}

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.