controller

Documentation

Index

• Variables
• type Cache
  • func NewCache[T any](ctx context.Context, dialer service.GrpcDialer, o Option) (*Cache[T], error)
  • func (q *Cache[T]) Close() error
  • func (q *Cache[T]) GetQueue(ctx context.Context, tentant string, queueID string) (provider.Queue[T], error)
• type Controller
  • func New(ctx context.Context, d service.GrpcDialer, o Option) (*Controller, error)
  • func (s *Controller) Close() error
  • func (s *Controller) Dequeue(in *pb.DequeueRequest) (*pb.DequeueReply, error)
  • func (s *Controller) Queue(in *pb.QueueRequest) (*pb.Void, error)
• type Option
• type QueueBuilder

Variables

var ErrQueueUnknown = errors.New("queue unknown")

Types

type Cache

type Cache[T any] struct {
	// contains filtered or unexported fields
}

func NewCache

func NewCache[T any](ctx context.Context, dialer service.GrpcDialer, o Option) (*Cache[T], error)

func (*Cache[T]) Close

func (q *Cache[T]) Close() error

func (*Cache[T]) GetQueue

func (q *Cache[T]) GetQueue(ctx context.Context, tentant string, queueID string) (provider.Queue[T], error)

type Controller

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

func New

func New(ctx context.Context, d service.GrpcDialer, o Option) (*Controller, error)

func (*Controller) Close

func (s *Controller) Close() error

func (*Controller) Dequeue

func (s *Controller) Dequeue(in *pb.DequeueRequest) (*pb.DequeueReply, error)

func (*Controller) Queue

func (s *Controller) Queue(in *pb.QueueRequest) (*pb.Void, error)

type Option

type Option struct {
	InMemory bool
	Dir      string
}

type QueueBuilder

type QueueBuilder[T any] func(string) (provider.Queue[T], error)