robotbroker

Documentation

Index

• Constants
• type RobotBrokerInterface
  • func NewRobotBrokerService(logger *zap.SugaredLogger, clientName string, natsUrl string) (RobotBrokerInterface, error)

Constants

const (
	CONSUMER_GROUP = "robot-"

	SUBJECT_TASK  = "task"
	SUBJECT_ROBOT = "robot"
)

Types

type RobotBrokerInterface

type RobotBrokerInterface interface {
	Close()
	CreateNewJetStream() (nats.JetStreamContext, error)
}

RobotBrokerInterface defines contracts for a message broker

func NewRobotBrokerService

func NewRobotBrokerService(
	logger *zap.SugaredLogger,
	clientName string,
	natsUrl string) (RobotBrokerInterface, error)

NewRobotBrokerService creates an concrete instance of RobotBrokerInterface