service

Documentation

Index

• func FormatAddress(addr string) string
• type Message
• type MessageChannel
• type PublisherConfig
• type PublisherService
  • func NewPublisherService(s *svcn.NatsService, ctx context.Context, cfg PublisherConfig, ...) *PublisherService
  • func (s PublisherService) Serve()
• type SubscriberConfig
• type SubscriberService
  • func NewSubscriberService(s *svcn.NatsService, ctx context.Context, cfg SubscriberConfig, ...) *SubscriberService
  • func (s SubscriberService) ProcessTxLogEventFromStream(data []byte) error
  • func (s SubscriberService) Serve()
• type Token

Functions

func FormatAddress

func FormatAddress(addr string) string

Types

type Message

type Message struct {
	Postfix string
	Msg     types.StreamData
}

type MessageChannel

type MessageChannel chan Message

type PublisherConfig

type PublisherConfig struct {
	SubjectPrefix string
}

type PublisherService

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

func NewPublisherService

func NewPublisherService(s *svcn.NatsService, ctx context.Context, cfg PublisherConfig, msgChan MessageChannel) *PublisherService

func (PublisherService) Serve

func (s PublisherService) Serve()

type SubscriberConfig

type SubscriberConfig struct{}

type SubscriberService

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

func NewSubscriberService

func NewSubscriberService(s *svcn.NatsService, ctx context.Context, cfg SubscriberConfig, msgChan MessageChannel) *SubscriberService

func (SubscriberService) ProcessTxLogEventFromStream

func (s SubscriberService) ProcessTxLogEventFromStream(data []byte) error

func (SubscriberService) Serve

func (s SubscriberService) Serve()

type Token

type Token struct {
	Ticker   string
	Decimals *big.Int
}