service

Documentation

Index

• type Deckard
  • func NewDeckardInstance(qpool messagepool.DeckardMessagePool, ...) *Deckard
  • func NewDeckardService(qpool messagepool.DeckardMessagePool, ...) *Deckard
  • func NewMemoryDeckardService(qpool messagepool.DeckardMessagePool, ...) *Deckard
  • func (d *Deckard) Ack(ctx context.Context, request *deckard.AckRequest) (*deckard.AckResponse, error)
  • func (d *Deckard) Add(ctx context.Context, request *deckard.AddRequest) (*deckard.AddResponse, error)
  • func (d *Deckard) Count(ctx context.Context, request *deckard.CountRequest) (*deckard.CountResponse, error)
  • func (d *Deckard) EditQueue(ctx context.Context, request *deckard.EditQueueRequest) (*deckard.EditQueueResponse, error)
  • func (d *Deckard) Flush(ctx context.Context, request *deckard.FlushRequest) (*deckard.FlushResponse, error)
  • func (d *Deckard) GetById(ctx context.Context, request *deckard.GetByIdRequest) (*deckard.GetByIdResponse, error)
  • func (d *Deckard) GetQueue(ctx context.Context, request *deckard.GetQueueRequest) (*deckard.GetQueueResponse, error)
  • func (d *Deckard) Nack(ctx context.Context, request *deckard.AckRequest) (*deckard.AckResponse, error)
  • func (d *Deckard) Pull(ctx context.Context, request *deckard.PullRequest) (*deckard.PullResponse, error)
  • func (d *Deckard) Remove(ctx context.Context, request *deckard.RemoveRequest) (*deckard.RemoveResponse, error)
  • func (d *Deckard) ServeGRPCServer(ctx context.Context) (*grpc.Server, error)

Types

type Deckard

type Deckard struct {
	deckard.UnimplementedDeckardServer
	// contains filtered or unexported fields
}

func NewDeckardInstance

func NewDeckardInstance(qpool messagepool.DeckardMessagePool, queueConfigurationService queue.ConfigurationService, memoryInstance bool) *Deckard

func NewDeckardService

func NewDeckardService(qpool messagepool.DeckardMessagePool, queueConfigurationService queue.ConfigurationService) *Deckard

Creates a non-memory deckard service

func NewMemoryDeckardService

func NewMemoryDeckardService(qpool messagepool.DeckardMessagePool, queueConfigurationService queue.ConfigurationService) *Deckard

Creates a memory deckard service

func (*Deckard) Ack

func (d *Deckard) Ack(ctx context.Context, request *deckard.AckRequest) (*deckard.AckResponse, error)

func (*Deckard) Add

func (d *Deckard) Add(ctx context.Context, request *deckard.AddRequest) (*deckard.AddResponse, error)

func (*Deckard) Count

func (d *Deckard) Count(ctx context.Context, request *deckard.CountRequest) (*deckard.CountResponse, error)

func (*Deckard) EditQueue

func (d *Deckard) EditQueue(ctx context.Context, request *deckard.EditQueueRequest) (*deckard.EditQueueResponse, error)

Edits a queue configuration

func (*Deckard) Flush

func (d *Deckard) Flush(ctx context.Context, request *deckard.FlushRequest) (*deckard.FlushResponse, error)

func (*Deckard) GetById

func (d *Deckard) GetById(ctx context.Context, request *deckard.GetByIdRequest) (*deckard.GetByIdResponse, error)

func (*Deckard) GetQueue

func (d *Deckard) GetQueue(ctx context.Context, request *deckard.GetQueueRequest) (*deckard.GetQueueResponse, error)

Gets the current configuration for a queue

func (*Deckard) Nack

func (d *Deckard) Nack(ctx context.Context, request *deckard.AckRequest) (*deckard.AckResponse, error)

func (*Deckard) Pull

func (d *Deckard) Pull(ctx context.Context, request *deckard.PullRequest) (*deckard.PullResponse, error)

func (*Deckard) Remove

func (d *Deckard) Remove(ctx context.Context, request *deckard.RemoveRequest) (*deckard.RemoveResponse, error)

func (*Deckard) ServeGRPCServer

func (d *Deckard) ServeGRPCServer(ctx context.Context) (*grpc.Server, error)