Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SaveState ¶
func SaveState(m *model.SomeProcessingTask) error
func StatesLength ¶
func StatesLength() int
func StatesLengthByID ¶
Types ¶
type Config ¶
Config for application
func (*Config) AMQPConfig ¶
AMQPConfig implements setup.AMQPConfigProvider
func (*Config) DatabaseConfig ¶
DatabaseConfig implements setup.DatabaseConfigProvider
func (*Config) HTTPConfig ¶
HTTPConfig implements setup.HTTPConfigProvider
type Handler ¶
type Handler struct {
// contains filtered or unexported fields
}
Handler ...
func (*Handler) LivenessHandler ¶
func (h *Handler) LivenessHandler() func(w http.ResponseWriter, r *http.Request)
LivenessHandler to check api response
type Items ¶
type Items struct {
// contains filtered or unexported fields
}
Items implements Processor
func NewItemsDomain ¶
func NewItemsDomain(repo *datasource.SampleProcessorDB, pbl rabbitmq.AMQPPublisher) *Items
NewItemsDomain constructor
func (*Items) UpdateItem ¶
UpdateItem ...
type Processor ¶
type Processor interface { Readiness() error UpdateItem(ctx context.Context, sip *model.SomeProcessingTask) error }
Processor represents sample usage of sample domain
Source Files ¶
Click to show internal directories.
Click to hide internal directories.