ack

Documentation

Index

• Constants
• type AckReactor
  • func NewAckReactor(supervisor AckSupervisor) *AckReactor
  • func (r *AckReactor) FuncNames() []string
  • func (r *AckReactor) React(req any) (bool, any, error)
• type AckSupervisor
• type DefaultAckSupervisor
  • func NewDefaultAckSupervisor(supervisor reactor.WaiterSupervisor, config *config.Config) *DefaultAckSupervisor
  • func (s *DefaultAckSupervisor) StartAckWaiter(subscriptionID string) *reactor.Waiter
  • func (s *DefaultAckSupervisor) StartNackWaiter(subscriptionID string) *reactor.Waiter
  • func (s *DefaultAckSupervisor) StopAckWaiter(subscriptionName string, ackIDs []string, err error)
  • func (s *DefaultAckSupervisor) StopNackWaiter(subscriptionName string, ackIDs []string, err error)

Constants

const (
	Ack  = "ack"
	Nack = "nack"
)

Types

type AckReactor

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

AckReactor is a pub/sub test server reactor for subscriptions message acks.

func NewAckReactor

func NewAckReactor(supervisor AckSupervisor) *AckReactor

NewAckReactor returns a new AckReactor instance.

func (*AckReactor) FuncNames

func (r *AckReactor) FuncNames() []string

FuncNames returns the list of function names this reactor will react to.

func (*AckReactor) React

func (r *AckReactor) React(req any) (bool, any, error)

React is the reactor logic.

type AckSupervisor

type AckSupervisor interface {
	StartAckWaiter(subscriptionID string) *reactor.Waiter
	StopAckWaiter(subscriptionName string, ackIDs []string, err error)
	StartNackWaiter(subscriptionID string) *reactor.Waiter
	StopNackWaiter(subscriptionName string, ackIDs []string, err error)
}

AckSupervisor is a reactor supervisor that reacts to acks ans nacks.

type DefaultAckSupervisor

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

DefaultAckSupervisor is the default AckSupervisor implementation.

func NewDefaultAckSupervisor

func NewDefaultAckSupervisor(supervisor reactor.WaiterSupervisor, config *config.Config) *DefaultAckSupervisor

NewDefaultAckSupervisor returns a new DefaultAckSupervisor instance.

func (*DefaultAckSupervisor) StartAckWaiter

func (s *DefaultAckSupervisor) StartAckWaiter(subscriptionID string) *reactor.Waiter

StartAckWaiter starts an ack waiter on a provided subscriptionID.

func (*DefaultAckSupervisor) StartNackWaiter

func (s *DefaultAckSupervisor) StartNackWaiter(subscriptionID string) *reactor.Waiter

StartNackWaiter starts a nack waiter on a provided subscriptionID.

func (*DefaultAckSupervisor) StopAckWaiter

func (s *DefaultAckSupervisor) StopAckWaiter(subscriptionName string, ackIDs []string, err error)

StopAckWaiter stop an ack waiter for a provided subscriptionName.

func (*DefaultAckSupervisor) StopNackWaiter

func (s *DefaultAckSupervisor) StopNackWaiter(subscriptionName string, ackIDs []string, err error)

StopNackWaiter stop a nack waiter for a provided subscriptionName.