dispatcher

Documentation

Index

• type Dispatcher
  • func NewOpenaiDispatcher() (Dispatcher, error)
  • func NewTaskDispatcher() (Dispatcher, error)
• type OpenaiDispatcher
  • func (od *OpenaiDispatcher) Add(taskAny any) error
  • func (od OpenaiDispatcher) Del(id string) error
  • func (od OpenaiDispatcher) Get(id string) (any, error)
  • func (od *OpenaiDispatcher) Run(taskAny any) error
• type TaskDispatcher
  • func (dd *TaskDispatcher) Add(taskAny any) error
  • func (dd TaskDispatcher) Del(id string) error
  • func (dd TaskDispatcher) Get(id string) (any, error)
  • func (dd *TaskDispatcher) Run(taskAny any) error

Types

type Dispatcher

type Dispatcher interface {
	Add(any) error
	Get(string) (any, error)
	Del(string) error
	Run(any) error
}

func NewOpenaiDispatcher

func NewOpenaiDispatcher() (Dispatcher, error)

func NewTaskDispatcher

func NewTaskDispatcher() (Dispatcher, error)

type OpenaiDispatcher

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

func (*OpenaiDispatcher) Add

func (od *OpenaiDispatcher) Add(taskAny any) error

func (OpenaiDispatcher) Del

func (od OpenaiDispatcher) Del(id string) error

func (OpenaiDispatcher) Get

func (od OpenaiDispatcher) Get(id string) (any, error)

func (*OpenaiDispatcher) Run

func (od *OpenaiDispatcher) Run(taskAny any) error

type TaskDispatcher

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

func (*TaskDispatcher) Add

func (dd *TaskDispatcher) Add(taskAny any) error

func (TaskDispatcher) Del

func (dd TaskDispatcher) Del(id string) error

func (TaskDispatcher) Get

func (dd TaskDispatcher) Get(id string) (any, error)

func (*TaskDispatcher) Run

func (dd *TaskDispatcher) Run(taskAny any) error