types

Mar 18, 2024

Changes in this version

type Metadata

+ func (m Metadata) ParseInt64(key string, defaultValue int64) int64

Sep 29, 2021

Changes in this version

+ func ParseResponseBody(body []byte) interface

+ type Activity struct

+ Binding string

+ CreatedAt time.Time

+ Error error

+ Id int64

+ Request *Request

+ Response *Response

+ func NewActivity() *Activity

+ type Metadata map[string]string

+ func NewMetadata() Metadata

+ func UnmarshallMetadata(meta string) (Metadata, error)

+ 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 struct

+ Data []byte

+ Metadata Metadata

+ func NewRequest() *Request

+ func ParseRequest(body []byte) (*Request, error)

+ 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 struct

+ Data []byte

+ Error string

+ IsError bool

+ Metadata Metadata

+ 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 struct

+ Data interface{}

+ Metadata Metadata

+ func NewTransportRequest() *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