ebt

Documentation

Index

• type CreateHistoryStreamHandler
• type CreateHistoryStreamHandlerAdapter
  • func NewCreateHistoryStreamHandlerAdapter(handler CreateHistoryStreamHandler) *CreateHistoryStreamHandlerAdapter
  • func (h CreateHistoryStreamHandlerAdapter) Handle(ctx context.Context, id refs.Feed, seq *message.Sequence, ...)
• type MessageWriterAdapter
  • func NewMessageWriterAdapter(messageWriter ebt.MessageWriter) *MessageWriterAdapter
  • func (m MessageWriterAdapter) CloseWithError(err error) error
  • func (m MessageWriterAdapter) WriteMessage(msg message.Message) error

Types

type CreateHistoryStreamHandler

type CreateHistoryStreamHandler interface {
	Handle(ctx context.Context, query queries.CreateHistoryStream)
}

type CreateHistoryStreamHandlerAdapter

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

func NewCreateHistoryStreamHandlerAdapter

func NewCreateHistoryStreamHandlerAdapter(handler CreateHistoryStreamHandler) *CreateHistoryStreamHandlerAdapter

func (CreateHistoryStreamHandlerAdapter) Handle

func (h CreateHistoryStreamHandlerAdapter) Handle(ctx context.Context, id refs.Feed, seq *message.Sequence, messageWriter ebt.MessageWriter)

type MessageWriterAdapter

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

func NewMessageWriterAdapter

func NewMessageWriterAdapter(messageWriter ebt.MessageWriter) *MessageWriterAdapter

func (MessageWriterAdapter) CloseWithError

func (m MessageWriterAdapter) CloseWithError(err error) error

func (MessageWriterAdapter) WriteMessage

func (m MessageWriterAdapter) WriteMessage(msg message.Message) error