service

Documentation

Index

• type AllMessageChannel
• type PublishService
  • func New(conn *nats.Conn, ctx context.Context, prefixName string, publisherName string, ...) *PublishService
  • func (s *PublishService) Serve(ctx context.Context)
  • func (s *PublishService) Start() context.Context

Types

type AllMessageChannel

type AllMessageChannel chan map[string]cmc.QuoteInfo

type PublishService

type PublishService struct {
	*service.Service
	// contains filtered or unexported fields
}

func New

func New(conn *nats.Conn, ctx context.Context, prefixName string, publisherName string, allMsgChan AllMessageChannel) *PublishService

func (*PublishService) Serve

func (s *PublishService) Serve(ctx context.Context)

func (*PublishService) Start

func (s *PublishService) Start() context.Context