queue

Documentation

Index

• type KafkaQueue
  • func (k *KafkaQueue) Defer() error
  • func (k *KafkaQueue) GetType() object.QueueType
  • func (k *KafkaQueue) SubmitClazz(unit *object.ClazzUploadUnit) (err error)
  • func (k *KafkaQueue) SubmitFunc(unit *object.FunctionUploadUnit) error
  • func (k *KafkaQueue) SubmitFuncCtx(unit *object.FunctionContextUploadUnit) error
  • func (k *KafkaQueue) WatchClazz(units chan<- *object.ClazzUploadUnit)
  • func (k *KafkaQueue) WatchFunc(units chan<- *object.FunctionUploadUnit)
  • func (k *KafkaQueue) WatchFuncCtx(units chan<- *object.FunctionContextUploadUnit)
• type MemoryQueue
  • func (q *MemoryQueue) Defer() error
  • func (q *MemoryQueue) GetType() object.QueueType
  • func (q *MemoryQueue) SubmitClazz(unit *object.ClazzUploadUnit) (err error)
  • func (q *MemoryQueue) SubmitFunc(unit *object.FunctionUploadUnit) error
  • func (q *MemoryQueue) SubmitFuncCtx(unit *object.FunctionContextUploadUnit) error
  • func (q *MemoryQueue) WatchClazz(c chan<- *object.ClazzUploadUnit)
  • func (q *MemoryQueue) WatchFunc(c chan<- *object.FunctionUploadUnit)
  • func (q *MemoryQueue) WatchFuncCtx(c chan<- *object.FunctionContextUploadUnit)
• type Queue
  • func InitQueue(config object.ExecuteConfig, ctx context.Context) Queue

Types

type KafkaQueue

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

func (*KafkaQueue) Defer

func (k *KafkaQueue) Defer() error

func (*KafkaQueue) GetType

func (k *KafkaQueue) GetType() object.QueueType

func (*KafkaQueue) SubmitClazz

func (k *KafkaQueue) SubmitClazz(unit *object.ClazzUploadUnit) (err error)

func (*KafkaQueue) SubmitFunc

func (k *KafkaQueue) SubmitFunc(unit *object.FunctionUploadUnit) error

func (*KafkaQueue) SubmitFuncCtx

func (k *KafkaQueue) SubmitFuncCtx(unit *object.FunctionContextUploadUnit) error

func (*KafkaQueue) WatchClazz

func (k *KafkaQueue) WatchClazz(units chan<- *object.ClazzUploadUnit)

func (*KafkaQueue) WatchFunc

func (k *KafkaQueue) WatchFunc(units chan<- *object.FunctionUploadUnit)

func (*KafkaQueue) WatchFuncCtx

func (k *KafkaQueue) WatchFuncCtx(units chan<- *object.FunctionContextUploadUnit)

type MemoryQueue

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

func (*MemoryQueue) Defer

func (q *MemoryQueue) Defer() error

func (*MemoryQueue) GetType

func (q *MemoryQueue) GetType() object.QueueType

func (*MemoryQueue) SubmitClazz

func (q *MemoryQueue) SubmitClazz(unit *object.ClazzUploadUnit) (err error)

func (*MemoryQueue) SubmitFunc

func (q *MemoryQueue) SubmitFunc(unit *object.FunctionUploadUnit) error

func (*MemoryQueue) SubmitFuncCtx

func (q *MemoryQueue) SubmitFuncCtx(unit *object.FunctionContextUploadUnit) error

func (*MemoryQueue) WatchClazz

func (q *MemoryQueue) WatchClazz(c chan<- *object.ClazzUploadUnit)

func (*MemoryQueue) WatchFunc

func (q *MemoryQueue) WatchFunc(c chan<- *object.FunctionUploadUnit)

func (*MemoryQueue) WatchFuncCtx

func (q *MemoryQueue) WatchFuncCtx(c chan<- *object.FunctionContextUploadUnit)

type Queue

type Queue interface {
	GetType() object.QueueType
	Defer() error
	SubmitFunc(unit *object.FunctionUploadUnit) (err error)
	SubmitFuncCtx(unit *object.FunctionContextUploadUnit) (err error)
	SubmitClazz(unit *object.ClazzUploadUnit) (err error)
	WatchFunc(chan<- *object.FunctionUploadUnit)
	WatchFuncCtx(chan<- *object.FunctionContextUploadUnit)
	WatchClazz(chan<- *object.ClazzUploadUnit)
}

func InitQueue

func InitQueue(config object.ExecuteConfig, ctx context.Context) Queue