message

package

v0.4.1 Latest Latest Go to latest Published: Mar 7, 2022 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/tkeel-io/core

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func GetAttributes(event cloudevents.Event) map[string]string
func ParseEntityFrom(msgCtx Context) *dao.Entity
type Context
- func From(ctx context.Context, ev cloudevents.Event) (Context, error)
- func New(ctx context.Context) Context
type Message
type MessageType
- func (mt MessageType) String() string

Constants ¶

View Source

const (
	// event Extension fields definitions.
	ExtEntityID     = "extenid"
	ExtEntityType   = "extentype"
	ExtEntityOwner  = "extowner"
	ExtEntitySource = "extsource"
	ExtTemplateID   = "exttemplate"
	ExtMessageID    = "extmsgid"
	ExtMessageType  = "extmsgtype"

	ExtSenderID     = "extsender"
	ExtSenderType   = "extsendertype"
	ExtSenderOwner  = "extsenderowner"
	ExtSenderSource = "extsendersource"

	ExtMessageReceiver = "extreceiver"
	ExtChannelID       = "extchid"
	ExtCallback        = "extcallback"
	ExtAPIIdentify     = "extapiid"
	ExtAPIRequestID    = "extreqid"
	ExtAPIRespStatus   = "extrespstatus"
	ExtAPIRespErrCode  = "extresperrcode"

	ExtCloudEventID           = "exteventid"
	ExtCloudEventSpec         = "exteventspec"
	ExtCloudEventType         = "exteventtype"
	ExtCloudEventTopic        = "exteventtopic"
	ExtCloudEventPubsub       = "exteventpubsub"
	ExtCloudEventSource       = "exteventsource"
	ExtCloudEventSubject      = "exteventsubject"
	ExtCloudEventDataSchema   = "exteventschema"
	ExtCloudEventContentType  = "exteventcontenttype"
	ExtCloudEventConsumerType = "exteventconsumertype"
)

Variables ¶

This section is empty.

Functions ¶

func GetAttributes ¶

func GetAttributes(event cloudevents.Event) map[string]string

func ParseEntityFrom ¶

func ParseEntityFrom(msgCtx Context) *dao.Entity

Types ¶

type Context ¶

type Context struct {
	// contains filtered or unexported fields
}

func From ¶

func From(ctx context.Context, ev cloudevents.Event) (Context, error)

func New ¶

func New(ctx context.Context) Context

func (*Context) Attributes ¶

func (ctx *Context) Attributes() map[string]string

func (*Context) Context ¶

func (ctx *Context) Context() context.Context

func (*Context) Get ¶

func (ctx *Context) Get(key string) string

func (*Context) Message ¶

func (ctx *Context) Message() []byte

func (*Context) Set ¶

func (ctx *Context) Set(key string, val string)

type Message ¶

type Message interface {
	Type() MessageType
}

type MessageType ¶

type MessageType string //nolint

const (
	MessageTypeRaw          MessageType = "raw"
	MessageTypeState        MessageType = "state"
	MessageTypeMapperInit   MessageType = "mapper"
	MessageTypeAPIRequest   MessageType = "apirequest"
	MessageTypeAPIRespond   MessageType = "apirespond"
	MessageTypeAPIRepublish MessageType = "republish"
)

func (MessageType) String ¶

func (mt MessageType) String() string

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL