stream

Documentation

Index

• func CreateCloudEvent(e *CloudEventInput) cloudevents.Event
• type CloudEventInput
• type EventStream
  • func (es *EventStream) GetAllNewsEvents(subject string) []*nats.Msg
  • func (es *EventStream) GetLastEvent(subject string) *nats.Msg
  • func (es *EventStream) PublishCloudEvent(input *CloudEventInput)
• type StreamServer
  • func Setup() *StreamServer
  • func (stream *StreamServer) Connect(name string) (*nats.Conn, *EventStream)

Functions

func CreateCloudEvent

func CreateCloudEvent(e *CloudEventInput) cloudevents.Event

Types

type CloudEventInput

type CloudEventInput struct {
	Id          string
	Source      string
	EventType   string
	PublishedAt time.Time
	Data        interface{}
}

type EventStream

type EventStream struct {
	nats.JetStreamContext
}

func (*EventStream) GetAllNewsEvents

func (es *EventStream) GetAllNewsEvents(subject string) []*nats.Msg

func (*EventStream) GetLastEvent

func (es *EventStream) GetLastEvent(subject string) *nats.Msg

func (*EventStream) PublishCloudEvent

func (es *EventStream) PublishCloudEvent(input *CloudEventInput)

type StreamServer

type StreamServer struct {
	*server.Server
}

func Setup

func Setup() *StreamServer

func (*StreamServer) Connect

func (stream *StreamServer) Connect(name string) (*nats.Conn, *EventStream)