eventscentrum

Documentation

Index

• Constants
• func BuildSubject(topic events.Topic, tType events.Type, job string) string
• func RegisterStream(ctx context.Context, js *events.JSWrapper) (jetstream.StreamConfig, error)
• func SplitSubject(subject string) (string, events.Topic, events.Type)

Constants

const (
	BaseSubject events.Subject = "centrum"

	TopicGeneral          events.Topic = "general"
	TypeGeneralSettings   events.Type  = "settings"
	TypeGeneralDisponents events.Type  = "disponents"

	TopicDispatch       events.Topic = "dispatch"
	TypeDispatchDeleted events.Type  = "deleted"
	TypeDispatchCreated events.Type  = "created"
	TypeDispatchUpdated events.Type  = "updated"
	TypeDispatchStatus  events.Type  = "status"

	TopicUnit       events.Topic = "unit"
	TypeUnitCreated events.Type  = "created"
	TypeUnitDeleted events.Type  = "deleted"
	TypeUnitUpdated events.Type  = "updated"
	TypeUnitStatus  events.Type  = "status"
)

Functions

func BuildSubject

func BuildSubject(topic events.Topic, tType events.Type, job string) string

Structure: "BASE_SUJBECT.JOB.TOPIC.TYPE.ID"

func RegisterStream

func RegisterStream(ctx context.Context, js *events.JSWrapper) (jetstream.StreamConfig, error)

func SplitSubject

func SplitSubject(subject string) (string, events.Topic, events.Type)