simplequeue

Documentation

Index

• Variables
• type RedisSimpleQueueService
  • func (s *RedisSimpleQueueService) SimpleQueueEmpty(ctx context.Context, in *pb.SimpleQueueRequest) (*pb.SimpleQueueEmptyResponse, error)
  • func (s *RedisSimpleQueueService) SimpleQueuePeek(ctx context.Context, in *pb.SimpleQueueRequest) (*pb.SimpleQueuePeekResponse, error)
  • func (s *RedisSimpleQueueService) SimpleQueuePop(ctx context.Context, in *pb.SimpleQueuePopRequest) (*pb.SimpleQueuePopResponse, error)
  • func (s *RedisSimpleQueueService) SimpleQueuePut(ctx context.Context, in *pb.SimpleQueuePutRequest) (*pb.SimpleQueuePutResponse, error)
  • func (s *RedisSimpleQueueService) SimpleQueueSize(ctx context.Context, in *pb.SimpleQueueRequest) (*pb.SimpleQueueSizeResponse, error)
• type SimpleQueueService
  • func NewRedisSimpleQueueService(rdb *common.RedisClient) (SimpleQueueService, error)

Variables

var Keys = &keys{}

Types

type RedisSimpleQueueService

type RedisSimpleQueueService struct {
	pb.UnimplementedSimpleQueueServiceServer
	// contains filtered or unexported fields
}

func (*RedisSimpleQueueService) SimpleQueueEmpty

func (s *RedisSimpleQueueService) SimpleQueueEmpty(ctx context.Context, in *pb.SimpleQueueRequest) (*pb.SimpleQueueEmptyResponse, error)

func (*RedisSimpleQueueService) SimpleQueuePeek

func (s *RedisSimpleQueueService) SimpleQueuePeek(ctx context.Context, in *pb.SimpleQueueRequest) (*pb.SimpleQueuePeekResponse, error)

func (*RedisSimpleQueueService) SimpleQueuePop

func (s *RedisSimpleQueueService) SimpleQueuePop(ctx context.Context, in *pb.SimpleQueuePopRequest) (*pb.SimpleQueuePopResponse, error)

func (*RedisSimpleQueueService) SimpleQueuePut

func (s *RedisSimpleQueueService) SimpleQueuePut(ctx context.Context, in *pb.SimpleQueuePutRequest) (*pb.SimpleQueuePutResponse, error)

Simple queue service implementations

func (*RedisSimpleQueueService) SimpleQueueSize

func (s *RedisSimpleQueueService) SimpleQueueSize(ctx context.Context, in *pb.SimpleQueueRequest) (*pb.SimpleQueueSizeResponse, error)

type SimpleQueueService

type SimpleQueueService interface {
	pb.SimpleQueueServiceServer
	SimpleQueuePut(ctx context.Context, in *pb.SimpleQueuePutRequest) (*pb.SimpleQueuePutResponse, error)
	SimpleQueuePop(ctx context.Context, in *pb.SimpleQueuePopRequest) (*pb.SimpleQueuePopResponse, error)
	SimpleQueuePeek(ctx context.Context, in *pb.SimpleQueueRequest) (*pb.SimpleQueuePeekResponse, error)
	SimpleQueueEmpty(ctx context.Context, in *pb.SimpleQueueRequest) (*pb.SimpleQueueEmptyResponse, error)
	SimpleQueueSize(ctx context.Context, in *pb.SimpleQueueRequest) (*pb.SimpleQueueSizeResponse, error)
}

func NewRedisSimpleQueueService

func NewRedisSimpleQueueService(rdb *common.RedisClient) (SimpleQueueService, error)