controller

package

v0.0.0-...-a686cab Latest Latest Go to latest Published: Sep 12, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

View Source

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

This section is empty.

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

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 struct {
	// contains filtered or unexported fields
}

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 struct {
	InMemory bool
	Dir      string
}

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