chronoqueue

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 16, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ChronoQueueServer 

type ChronoQueueServer struct {
	queueservice_pb.UnimplementedQueueServiceServer
	// contains filtered or unexported fields
}

ChronoQueueServer implements the gRPC QueueService interface directly using the storage layer without intermediate service abstractions

func NewChronoQueueServer 

func NewChronoQueueServer(storage repository.Storage, schemaRegistry schema.Registry, logger *log.Logger) *ChronoQueueServer

NewChronoQueueServer creates a new gRPC server instance

func (*ChronoQueueServer) AcknowledgeMessage 

func (s *ChronoQueueServer) AcknowledgeMessage(ctx context.Context, req *queueservice_pb.AcknowledgeMessageRequest) (*queueservice_pb.AcknowledgeMessageResponse, error)

func (*ChronoQueueServer) CreateQueue 

func (s *ChronoQueueServer) CreateQueue(ctx context.Context, req *queueservice_pb.CreateQueueRequest) (*queueservice_pb.CreateQueueResponse, error)

func (*ChronoQueueServer) CreateSchedule 

func (s *ChronoQueueServer) CreateSchedule(ctx context.Context, req *queueservice_pb.CreateScheduleRequest) (*queueservice_pb.CreateScheduleResponse, error)

func (*ChronoQueueServer) DeleteFromDLQ 

func (s *ChronoQueueServer) DeleteFromDLQ(ctx context.Context, req *queueservice_pb.DeleteFromDLQRequest) (*queueservice_pb.DeleteFromDLQResponse, error)

func (*ChronoQueueServer) DeleteQueue 

func (s *ChronoQueueServer) DeleteQueue(ctx context.Context, req *queueservice_pb.DeleteQueueRequest) (*queueservice_pb.DeleteQueueResponse, error)

func (*ChronoQueueServer) DeleteSchedule 

func (s *ChronoQueueServer) DeleteSchedule(ctx context.Context, req *queueservice_pb.DeleteScheduleRequest) (*queueservice_pb.DeleteScheduleResponse, error)

func (*ChronoQueueServer) DeleteSchema 

func (s *ChronoQueueServer) DeleteSchema(ctx context.Context, req *queueservice_pb.DeleteSchemaRequest) (*queueservice_pb.DeleteSchemaResponse, error)

func (*ChronoQueueServer) GetDLQMessages 

func (s *ChronoQueueServer) GetDLQMessages(ctx context.Context, req *queueservice_pb.GetDLQMessagesRequest) (*queueservice_pb.GetDLQMessagesResponse, error)

func (*ChronoQueueServer) GetDLQStats 

func (s *ChronoQueueServer) GetDLQStats(ctx context.Context, req *queueservice_pb.GetDLQStatsRequest) (*queueservice_pb.GetDLQStatsResponse, error)

func (*ChronoQueueServer) GetNextMessage 

func (s *ChronoQueueServer) GetNextMessage(ctx context.Context, req *queueservice_pb.GetNextMessageRequest) (*queueservice_pb.GetNextMessageResponse, error)

func (*ChronoQueueServer) GetQueueState 

func (s *ChronoQueueServer) GetQueueState(ctx context.Context, req *queueservice_pb.GetQueueStateRequest) (*queueservice_pb.GetQueueStateResponse, error)

func (*ChronoQueueServer) GetSchedule 

func (s *ChronoQueueServer) GetSchedule(ctx context.Context, req *queueservice_pb.GetScheduleRequest) (*queueservice_pb.GetScheduleResponse, error)

func (*ChronoQueueServer) GetScheduleHistory 

func (s *ChronoQueueServer) GetScheduleHistory(ctx context.Context, req *queueservice_pb.GetScheduleHistoryRequest) (*queueservice_pb.GetScheduleHistoryResponse, error)

func (*ChronoQueueServer) GetSchema 

func (s *ChronoQueueServer) GetSchema(ctx context.Context, req *queueservice_pb.GetSchemaRequest) (*queueservice_pb.GetSchemaResponse, error)

func (*ChronoQueueServer) ListQueues 

func (s *ChronoQueueServer) ListQueues(ctx context.Context, req *queueservice_pb.ListQueuesRequest) (*queueservice_pb.ListQueuesResponse, error)

func (*ChronoQueueServer) ListSchedules 

func (s *ChronoQueueServer) ListSchedules(ctx context.Context, req *queueservice_pb.ListSchedulesRequest) (*queueservice_pb.ListSchedulesResponse, error)

func (*ChronoQueueServer) ListSchemas 

func (s *ChronoQueueServer) ListSchemas(ctx context.Context, req *queueservice_pb.ListSchemasRequest) (*queueservice_pb.ListSchemasResponse, error)

func (*ChronoQueueServer) PauseSchedule 

func (s *ChronoQueueServer) PauseSchedule(ctx context.Context, req *queueservice_pb.PauseScheduleRequest) (*queueservice_pb.PauseScheduleResponse, error)

func (*ChronoQueueServer) PeekQueueMessages 

func (s *ChronoQueueServer) PeekQueueMessages(ctx context.Context, req *queueservice_pb.PeekQueueMessagesRequest) (*queueservice_pb.PeekQueueMessagesResponse, error)

func (*ChronoQueueServer) PostMessage 

func (s *ChronoQueueServer) PostMessage(ctx context.Context, req *queueservice_pb.PostMessageRequest) (*queueservice_pb.PostMessageResponse, error)

func (*ChronoQueueServer) PreviewCalendarSchedule 

func (s *ChronoQueueServer) PreviewCalendarSchedule(ctx context.Context, req *queueservice_pb.PreviewCalendarScheduleRequest) (*queueservice_pb.PreviewCalendarScheduleResponse, error)

func (*ChronoQueueServer) PurgeDLQ 

func (s *ChronoQueueServer) PurgeDLQ(ctx context.Context, req *queueservice_pb.PurgeDLQRequest) (*queueservice_pb.PurgeDLQResponse, error)

func (*ChronoQueueServer) RegisterSchema 

func (s *ChronoQueueServer) RegisterSchema(ctx context.Context, req *queueservice_pb.RegisterSchemaRequest) (*queueservice_pb.RegisterSchemaResponse, error)

func (*ChronoQueueServer) RenewMessageLease 

func (s *ChronoQueueServer) RenewMessageLease(ctx context.Context, req *queueservice_pb.RenewMessageLeaseRequest) (*queueservice_pb.RenewMessageLeaseResponse, error)

func (*ChronoQueueServer) RequeueFromDLQ 

func (s *ChronoQueueServer) RequeueFromDLQ(ctx context.Context, req *queueservice_pb.RequeueFromDLQRequest) (*queueservice_pb.RequeueFromDLQResponse, error)

func (*ChronoQueueServer) ResumeSchedule 

func (s *ChronoQueueServer) ResumeSchedule(ctx context.Context, req *queueservice_pb.ResumeScheduleRequest) (*queueservice_pb.ResumeScheduleResponse, error)

func (*ChronoQueueServer) SendMessageHeartBeat 

func (s *ChronoQueueServer) SendMessageHeartBeat(ctx context.Context, req *queueservice_pb.SendMessageHeartBeatRequest) (*queueservice_pb.SendMessageHeartBeatResponse, error)

func (*ChronoQueueServer) ValidateCalendarSchedule 

func (s *ChronoQueueServer) ValidateCalendarSchedule(ctx context.Context, req *queueservice_pb.ValidateCalendarScheduleRequest) (*queueservice_pb.ValidateCalendarScheduleResponse, error)

func (*ChronoQueueServer) ValidatePayload 

func (s *ChronoQueueServer) ValidatePayload(ctx context.Context, req *queueservice_pb.ValidatePayloadRequest) (*queueservice_pb.ValidatePayloadResponse, error)

type Service 

type Service interface {
	CreateQueue(ctx context.Context, request *queueservice_pb.CreateQueueRequest) (*queueservice_pb.CreateQueueResponse, error)
	DeleteQueue(ctx context.Context, request *queueservice_pb.DeleteQueueRequest) (*queueservice_pb.DeleteQueueResponse, error)
	PostMessage(ctx context.Context, request *queueservice_pb.PostMessageRequest) (*queueservice_pb.PostMessageResponse, error)
	GetNextMessage(ctx context.Context, request *queueservice_pb.GetNextMessageRequest) (*queueservice_pb.GetNextMessageResponse, error)
	AcknowledgeMessage(ctx context.Context, request *queueservice_pb.AcknowledgeMessageRequest) (*queueservice_pb.AcknowledgeMessageResponse, error)
	RenewMessageLease(ctx context.Context, request *queueservice_pb.RenewMessageLeaseRequest) (*queueservice_pb.RenewMessageLeaseResponse, error)
	PeekQueueMessages(ctx context.Context, request *queueservice_pb.PeekQueueMessagesRequest) (*queueservice_pb.PeekQueueMessagesResponse, error)
	GetQueueState(ctx context.Context, request *queueservice_pb.GetQueueStateRequest) (*queueservice_pb.GetQueueStateResponse, error)
	SendMessageHeartBeat(ctx context.Context, request *queueservice_pb.SendMessageHeartBeatRequest) (*queueservice_pb.SendMessageHeartBeatResponse, error)
	ListQueues(ctx context.Context, request *queueservice_pb.ListQueuesRequest) (*queueservice_pb.ListQueuesResponse, error)
	CreateSchedule(ctx context.Context, request *queueservice_pb.CreateScheduleRequest) (*queueservice_pb.CreateScheduleResponse, error)
	DeleteSchedule(ctx context.Context, request *queueservice_pb.DeleteScheduleRequest) (*queueservice_pb.DeleteScheduleResponse, error)
	GetSchedule(ctx context.Context, request *queueservice_pb.GetScheduleRequest) (*queueservice_pb.GetScheduleResponse, error)
	ListSchedules(ctx context.Context, request *queueservice_pb.ListSchedulesRequest) (*queueservice_pb.ListSchedulesResponse, error)
	GetScheduleHistory(ctx context.Context, request *queueservice_pb.GetScheduleHistoryRequest) (*queueservice_pb.GetScheduleHistoryResponse, error)
	PauseSchedule(ctx context.Context, request *queueservice_pb.PauseScheduleRequest) (*queueservice_pb.PauseScheduleResponse, error)
	ResumeSchedule(ctx context.Context, request *queueservice_pb.ResumeScheduleRequest) (*queueservice_pb.ResumeScheduleResponse, error)

	// calendar-based scheduling operations
	ValidateCalendarSchedule(ctx context.Context, request *queueservice_pb.ValidateCalendarScheduleRequest) (*queueservice_pb.ValidateCalendarScheduleResponse, error)
	PreviewCalendarSchedule(ctx context.Context, request *queueservice_pb.PreviewCalendarScheduleRequest) (*queueservice_pb.PreviewCalendarScheduleResponse, error)

	// Dead Letter Queue Management Operations
	GetDLQMessages(ctx context.Context, request *queueservice_pb.GetDLQMessagesRequest) (*queueservice_pb.GetDLQMessagesResponse, error)
	RequeueFromDLQ(ctx context.Context, request *queueservice_pb.RequeueFromDLQRequest) (*queueservice_pb.RequeueFromDLQResponse, error)
	DeleteFromDLQ(ctx context.Context, request *queueservice_pb.DeleteFromDLQRequest) (*queueservice_pb.DeleteFromDLQResponse, error)
	PurgeDLQ(ctx context.Context, request *queueservice_pb.PurgeDLQRequest) (*queueservice_pb.PurgeDLQResponse, error)
	GetDLQStats(ctx context.Context, request *queueservice_pb.GetDLQStatsRequest) (*queueservice_pb.GetDLQStatsResponse, error)

	// Schema Management Operations
	RegisterSchema(ctx context.Context, request *queueservice_pb.RegisterSchemaRequest) (*queueservice_pb.RegisterSchemaResponse, error)
	GetSchema(ctx context.Context, request *queueservice_pb.GetSchemaRequest) (*queueservice_pb.GetSchemaResponse, error)
	ListSchemas(ctx context.Context, request *queueservice_pb.ListSchemasRequest) (*queueservice_pb.ListSchemasResponse, error)
	DeleteSchema(ctx context.Context, request *queueservice_pb.DeleteSchemaRequest) (*queueservice_pb.DeleteSchemaResponse, error)
	ValidatePayload(ctx context.Context, request *queueservice_pb.ValidatePayloadRequest) (*queueservice_pb.ValidatePayloadResponse, error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.