manager

Documentation

Index

• Constants
• type Options
  • func DefaultOptions() Options
• type TaskManager
  • func New(nc *nats.Conn, opts Options) *TaskManager
  • func (mgr *TaskManager) Start(ctx context.Context, jsmOpts ...nats.JSOpt) error
  • func (mgr *TaskManager) Submit(t tasks.TaskType, tenantID, taskID, respID, title string, data any, ...) (*TaskResponse, error)
• type TaskResponse
• type TaskStatus

Constants

const (
	EventExtTitle  = "title"
	EventExtRespID = "respID"
	EventExtNotify = "notify"
)

const (
	TaskStatusPending = "Pending"
	TaskStatusStarted = "Started"
	TaskStatusRunning = "Running"
	TaskStatusFailed  = "Failed"
	TaskStatusSuccess = "Success"
)

Types

type Options

type Options struct {
	RequestTimeout time.Duration
	AckWait        time.Duration

	// same as stream
	Stream string

	// manager id, < 0 means auto detect
	Id int
	// hostname
	Name string

	NumReplicas int
	NumWorkers  int

	// sends
	ResponseSubjectPrefix     string
	NotificationSubjectPrefix string

	LogNatsError bool
}

func DefaultOptions

func DefaultOptions() Options

type TaskManager

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

func New

func New(nc *nats.Conn, opts Options) *TaskManager

func (*TaskManager) Start

func (mgr *TaskManager) Start(ctx context.Context, jsmOpts ...nats.JSOpt) error

func (*TaskManager) Submit

func (mgr *TaskManager) Submit(t tasks.TaskType, tenantID, taskID, respID, title string, data any, notify bool) (*TaskResponse, error)

type TaskResponse

type TaskResponse struct {
	ID      string `json:"id,omitempty"`
	Subject string `json:"subject,omitempty"`
}

type TaskStatus

type TaskStatus string