reader

Documentation

Index

• Constants
• Variables
• func NewPublisherMock() model.MessageWriter
• type NewStreamFunc
• type PublisherPool
  • func NewPublisherPool(newStreamFunc NewStreamFunc, limit uint32) (pool PublisherPool)
• type Service
  • func NewLoggingMiddleware(svc Service, log *slog.Logger) Service
  • func NewService(client ServiceClient, poolCfg config.ReaderPoolConfig) (svc Service)
  • func NewServiceMock() Service

Constants

const KeySubId = "x-awakari-sub-id"

Variables

var ErrInternal = errors.New("reader: internal failure")

Functions

func NewPublisherMock

func NewPublisherMock() model.MessageWriter

Types

type NewStreamFunc

type NewStreamFunc func(ctx context.Context, subId string) (stream Service_PublishMessagesClient, err error)

type PublisherPool

type PublisherPool interface {
	Get(ctx context.Context, subId string) (mw model.MessageWriter, err error)
	Remove(subId string)
}

func NewPublisherPool

func NewPublisherPool(newStreamFunc NewStreamFunc, limit uint32) (pool PublisherPool)

type Service

type Service interface {
	MessagePublisher(ctx context.Context, subId string) (mw model.MessageWriter, err error)
}

func NewLoggingMiddleware

func NewLoggingMiddleware(svc Service, log *slog.Logger) Service

func NewService

func NewService(client ServiceClient, poolCfg config.ReaderPoolConfig) (svc Service)

func NewServiceMock

func NewServiceMock() Service