dispatcher

package
v0.0.0-...-d33b70a Latest Latest
Warning

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

Go to latest
Published: Oct 26, 2023 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL