trigger

type Config struct {
	TriggerAddr    string
	Port           int                  `yaml:"port"`
	IP             string               `yaml:"ip"`
	ControllerAddr []string             `yaml:"controllers"`
	Observability  observability.Config `yaml:"observability"`

	HeartbeatInterval time.Duration `yaml:"heartbeat_interval"`
	// send event goroutine size
	SendEventGoroutineSize int `yaml:"send_event_goroutine_size"`
	// push event batch size when use grpc
	SendEventBatchSize int `yaml:"send_event_batch_size"`
	// var client read event from segment batch size.
	PullEventBatchSize int `yaml:"pull_event_batch_size"`
	// max uack event number
	MaxUACKEventNumber int `yaml:"max_uack_event_number"`
}

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

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

type Worker interface {
	Init(ctx context.Context) error
	Register(ctx context.Context) error
	Unregister(ctx context.Context) error
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	AddSubscription(ctx context.Context, subscription *primitive.Subscription) error
	RemoveSubscription(ctx context.Context, id vanus.ID) error
	PauseSubscription(ctx context.Context, id vanus.ID) error
	StartSubscription(ctx context.Context, id vanus.ID) error
}