internal

Documentation

Index

• type IProducer
• type IServer
• type ServiceInterface
• type WebhooksService
  • func NewWebhooksService(server IServer, producer IProducer) *WebhooksService
  • func (s *WebhooksService) PublishMessage(data []byte) error
  • func (s *WebhooksService) Start() error
  • func (s *WebhooksService) Stop()

Types

type IProducer

type IProducer interface {
	PublishMessage(data []byte) error
	CloseConn()
}

IProducer ...

type IServer

type IServer interface {
	ListenAndServe() error
}

IServer ...

type ServiceInterface

type ServiceInterface interface {
	Start() error
	Stop()
	PublishMessage([]byte) error
}

ServiceInterface ...

type WebhooksService

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

WebhooksService ...

func NewWebhooksService

func NewWebhooksService(server IServer, producer IProducer) *WebhooksService

NewWebhooksService ...

func (*WebhooksService) PublishMessage

func (s *WebhooksService) PublishMessage(data []byte) error

PublishMessage ...

func (*WebhooksService) Start

func (s *WebhooksService) Start() error

Start starts the service. Start will block.

func (*WebhooksService) Stop

func (s *WebhooksService) Stop()

Stop attempts to gracefully stop the service. It also closes any open connection that remains to the producer.