messagequeue

Documentation

Index

• Constants
• type Subscriber
  • func NewSubscriber(ctx context.Context, env *environment.Environment, ...) (*Subscriber, error)
  • func (s *Subscriber) StartConsumer()

Constants

const (
	SubscriberName = "UNWINDIA_PTERODACTYL"
)

Types

type Subscriber

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

func NewSubscriber

func NewSubscriber(ctx context.Context, env *environment.Environment, matchInfoChan chan *messagebroker.Message) (*Subscriber, error)

func (*Subscriber) StartConsumer

func (s *Subscriber) StartConsumer()