service

Documentation

Index

• Variables
• type JobService
  • func NewJobService() *JobService
  • func (js *JobService) Init()
• type MessageService
  • func NewMessageService() *MessageService
  • func (s *MessageService) ReSend(queue, start, end string) models.Result[any]
  • func (s *MessageService) Send(queue, msg string) models.Result[any]

Variables

var ParamsType string

Types

type JobService

type JobService struct{}

func NewJobService

func NewJobService() *JobService

func (*JobService) Init

func (js *JobService) Init()

type MessageService

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

func NewMessageService

func NewMessageService() *MessageService

func (*MessageService) ReSend

func (s *MessageService) ReSend(queue, start, end string) models.Result[any]

func (*MessageService) Send

func (s *MessageService) Send(queue, msg string) models.Result[any]