events

package

v0.0.21 Latest Latest Go to latest Published: Jan 5, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation ¶

This section is empty.

View Source

var Factory = &Event{}

This section is empty.

type DeploymentProducer struct {
	Config             config.Config
	DeploymentProducer interfaces.Producer
	DoneProducer       interfaces.Producer
}

func (this *DeploymentProducer) Produce(command messages.DeploymentCommand) error

type DoneNotification struct {
	Command string `json:"command"`
	Id      string `json:"id"`
	Handler string `json:"handler"`
}

type Event struct{}

func (this *Event) NewDeploymentProducer(ctx context.Context, config config.Config) (interfaces.DeploymentProducer, error)

func (this *Event) NewDeviceGroupConsumer(ctx context.Context, config config.Config, listener func(groupId string) error) error

func (this *Event) NewUserCommandConsumer(ctx context.Context, config config.Config, listener func(delivery messages.UserCommandMsg) error) error

Path	Synopsis
kafka