Documentation ¶
Index ¶
- func ParseResponseBody(body []byte) interface{}
- type Activity
- type Metadata
- func (m Metadata) Get(key string) string
- func (m Metadata) GetValidMethodTypes(methodsMap map[string]string) error
- func (m Metadata) GetValidSupportedTypes(possibleValues map[string]string, typeName string) error
- func (m Metadata) MustNotParseString(key string, conflictValueName string) (string, error)
- func (m Metadata) MustParseAddress(key, defaultValue string) (string, int, error)
- func (m Metadata) MustParseBool(key string) (bool, error)
- func (m Metadata) MustParseEnv(key, envVar, defaultValue string) (string, error)
- func (m Metadata) MustParseInt(key string) (int, error)
- func (m Metadata) MustParseIntWithRange(key string, min, max int) (int, error)
- func (m Metadata) MustParseInterfaceMap(key string) (map[string]interface{}, error)
- func (m Metadata) MustParseJsonMap(key string) (map[string]string, error)
- func (m Metadata) MustParseString(key string) (string, error)
- func (m Metadata) MustParseStringList(key string) ([]string, error)
- func (m Metadata) ParseBool(key string, defaultValue bool) bool
- func (m Metadata) ParseInt(key string, defaultValue int) int
- func (m Metadata) ParseIntWithRange(key string, defaultValue, min, max int) (int, error)
- func (m Metadata) ParseOSFileMode(key string, defaultValue os.FileMode) os.FileMode
- func (m Metadata) ParseString(key, defaultValue string) string
- func (m Metadata) ParseStringMap(key string, stringMap map[string]string) (string, error)
- func (m Metadata) ParseTimeDuration(key string, defaultValue int) time.Duration
- func (m Metadata) Set(key, value string) Metadata
- func (m Metadata) String() string
- type Request
- func (r *Request) MarshalBinary() []byte
- func (r *Request) SetData(value []byte) *Request
- func (r *Request) SetMetadata(value Metadata) *Request
- func (r *Request) SetMetadataKeyValue(key, value string) *Request
- func (r *Request) Size() float64
- func (r *Request) String() string
- func (r *Request) ToCommand() *kubemq.Command
- func (r *Request) ToEvent() *kubemq.Event
- func (r *Request) ToEventStore() *kubemq.EventStore
- func (r *Request) ToQuery() *kubemq.Query
- func (r *Request) ToQueueMessage() *kubemq.QueueMessage
- type Response
- func NewResponse() *Response
- func ParseResponse(body []byte) (*Response, error)
- func ParseResponseFromCommandResponse(resp *kubemq.CommandResponse) (*Response, error)
- func ParseResponseFromEvent(event *kubemq.Event) (*Response, error)
- func ParseResponseFromEventReceive(event *kubemq.EventStoreReceive) (*Response, error)
- func ParseResponseFromQueryResponse(resp *kubemq.QueryResponse) (*Response, error)
- func ParseResponseFromQueueMessage(resp *kubemq.QueueMessage) (*Response, error)
- func (r *Response) MarshalBinary() []byte
- func (r *Response) SetData(value []byte) *Response
- func (r *Response) SetError(err error) *Response
- func (r *Response) SetMetadata(value Metadata) *Response
- func (r *Response) SetMetadataKeyValue(key, value string) *Response
- func (r *Response) Size() float64
- func (r *Response) String() string
- func (r *Response) ToCommand() *kubemq.Command
- func (r *Response) ToEvent() *kubemq.Event
- func (r *Response) ToEventStore() *kubemq.EventStore
- func (r *Response) ToQuery() *kubemq.Query
- func (r *Response) ToQueueMessage() *kubemq.QueueMessage
- func (r *Response) ToQueueStreamMessage() *queues_stream.QueueMessage
- func (r *Response) ToResponse() *kubemq.Response
- type TransportRequest
- func (r *TransportRequest) MarshalBinary() []byte
- func (r *TransportRequest) SetData(value interface{}) *TransportRequest
- func (r *TransportRequest) SetMetadata(value Metadata) *TransportRequest
- func (r *TransportRequest) SetMetadataKeyValue(key, value string) *TransportRequest
- func (r *TransportRequest) ToEvent() *kubemq.Event
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ParseResponseBody ¶
func ParseResponseBody(body []byte) interface{}
Types ¶
type Activity ¶
type Activity struct { Id int64 `storm:"id,increment"` Binding string `storm:"index"` CreatedAt time.Time Request *Request Response *Response Error error }
func NewActivity ¶
func NewActivity() *Activity
type Metadata ¶
func NewMetadata ¶
func NewMetadata() Metadata
func UnmarshallMetadata ¶
func (Metadata) GetValidMethodTypes ¶
func (Metadata) GetValidSupportedTypes ¶
func (Metadata) MustNotParseString ¶
func (Metadata) MustParseAddress ¶
func (Metadata) MustParseEnv ¶
func (Metadata) MustParseIntWithRange ¶
func (Metadata) MustParseInterfaceMap ¶
func (Metadata) MustParseJsonMap ¶
func (Metadata) MustParseStringList ¶
func (Metadata) ParseIntWithRange ¶
func (Metadata) ParseOSFileMode ¶
func (Metadata) ParseString ¶
func (Metadata) ParseStringMap ¶
func (Metadata) ParseTimeDuration ¶
type Request ¶
type Request struct { Metadata Metadata `json:"metadata,omitempty"` Data []byte `json:"data,omitempty"` }
func NewRequest ¶
func NewRequest() *Request
func ParseRequest ¶
func (*Request) MarshalBinary ¶
func (*Request) SetMetadata ¶
func (*Request) SetMetadataKeyValue ¶
func (*Request) ToEventStore ¶
func (r *Request) ToEventStore() *kubemq.EventStore
func (*Request) ToQueueMessage ¶
func (r *Request) ToQueueMessage() *kubemq.QueueMessage
type Response ¶
type Response struct { Metadata Metadata `json:"metadata"` Data []byte `json:"data"` IsError bool `json:"is_error"` Error string `json:"error"` }
func NewResponse ¶
func NewResponse() *Response
func ParseResponse ¶
func ParseResponseFromEvent ¶
func (*Response) MarshalBinary ¶
func (*Response) SetMetadata ¶
func (*Response) SetMetadataKeyValue ¶
func (*Response) ToEventStore ¶
func (r *Response) ToEventStore() *kubemq.EventStore
func (*Response) ToQueueMessage ¶
func (r *Response) ToQueueMessage() *kubemq.QueueMessage
func (*Response) ToQueueStreamMessage ¶
func (r *Response) ToQueueStreamMessage() *queues_stream.QueueMessage
func (*Response) ToResponse ¶
func (r *Response) ToResponse() *kubemq.Response
type TransportRequest ¶
type TransportRequest struct { Metadata Metadata `json:"metadata,omitempty"` Data interface{} `json:"data,omitempty"` }
func NewTransportRequest ¶
func NewTransportRequest() *TransportRequest
func (*TransportRequest) MarshalBinary ¶
func (r *TransportRequest) MarshalBinary() []byte
func (*TransportRequest) SetData ¶
func (r *TransportRequest) SetData(value interface{}) *TransportRequest
func (*TransportRequest) SetMetadata ¶
func (r *TransportRequest) SetMetadata(value Metadata) *TransportRequest
func (*TransportRequest) SetMetadataKeyValue ¶
func (r *TransportRequest) SetMetadataKeyValue(key, value string) *TransportRequest
func (*TransportRequest) ToEvent ¶
func (r *TransportRequest) ToEvent() *kubemq.Event
Click to show internal directories.
Click to hide internal directories.