microservice

Documentation

Index

• type Delegate
• type Message
• type Service
  • func New(name string) *Service
  • func (m *Service) FindHandler(itopic string) (delegate Delegate, exists bool)
  • func (m *Service) Loop()
  • func (m *Service) Register(r string) error
  • func (m *Service) RegisterAndSubscribe(register []string, subscribe []string)
  • func (m *Service) RegisterHandler(topic string, delegate Delegate)
  • func (m *Service) Subscribe(r string) error

Types

type Delegate

type Delegate func(m *Service, topic string, message []byte) bool

Delegate is a handler that the user can register on a certain received topic

type Message

type Message struct {
	Topic   string
	Payload []byte
}

type Service

type Service struct {
	Name            string
	Logger          *logpkg.Logger
	PubsubRegister  []string
	PubsubSubscribe []string
	Pubsub          *pubsub.Context
	Handlers        map[string]Delegate
	CatchHandler    Delegate
	ProcessMessages chan *Message
}

Service is a convenience setup to implement a micro-service

func New

func New(name string) *Service

func (*Service) FindHandler

func (m *Service) FindHandler(itopic string) (delegate Delegate, exists bool)

func (*Service) Loop

func (m *Service) Loop()

func (*Service) Register

func (m *Service) Register(r string) error

func (*Service) RegisterAndSubscribe

func (m *Service) RegisterAndSubscribe(register []string, subscribe []string)

func (*Service) RegisterHandler

func (m *Service) RegisterHandler(topic string, delegate Delegate)

func (*Service) Subscribe

func (m *Service) Subscribe(r string) error