subscriber

Documentation

Index

• Variables
• type Config
• type HandleProcessError
  • func NewHandleProcessError(msg string, err error) *HandleProcessError
  • func (e HandleProcessError) Error() string
• type MonitorSubscriber
  • func NewMonitorSubscriber(cfg *Config, log logger.Logger, sub message.Subscriber, router *message.Router, ...) (*MonitorSubscriber, error)
  • func (s *MonitorSubscriber) RegisterProcessHandler()
  • func (s *MonitorSubscriber) Run(ctx context.Context) error
• type MonitorSubscriberError
  • func NewMonitorSubscriberError(msg string, err error) *MonitorSubscriberError
  • func (e MonitorSubscriberError) Error() string

Variables

var ErrFailedVerification = errors.New("failed verification")

var ErrNilConfig = errors.New("cannot override nil config")

Types

type Config

type Config struct {
	ProcessTopic string
}

Config represents the monitor configuration structure.

type HandleProcessError

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

func NewHandleProcessError

func NewHandleProcessError(msg string, err error) *HandleProcessError

func (HandleProcessError) Error

func (e HandleProcessError) Error() string

type MonitorSubscriber

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

MonitorSubscriber represents a subscriber for monitoring.

func NewMonitorSubscriber

func NewMonitorSubscriber(
	cfg *Config,
	log logger.Logger,
	sub message.Subscriber,
	router *message.Router,
	monitorPub publisher.MonitorPublisher,
) (*MonitorSubscriber, error)

NewMonitorSubscriber creates a new MonitorSubscriber instance.

func (*MonitorSubscriber) RegisterProcessHandler

func (s *MonitorSubscriber) RegisterProcessHandler()

RegisterProcessHandler registers the process handler for the monitor subscriber.

func (*MonitorSubscriber) Run

func (s *MonitorSubscriber) Run(ctx context.Context) error

Run starts the monitor subscriber's router.

type MonitorSubscriberError

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

func NewMonitorSubscriberError

func NewMonitorSubscriberError(msg string, err error) *MonitorSubscriberError

func (MonitorSubscriberError) Error

func (e MonitorSubscriberError) Error() string