service

type Service interface {
	Register(ctx context.Context, req domain.Worker) (int64, error)
	FindOrRegisterByName(ctx context.Context, req domain.Worker) (domain.Worker, error)
	FindOrRegisterByKey(ctx context.Context, req domain.Worker) (domain.Worker, error)
	ListWorker(ctx context.Context, offset, limit int64) ([]domain.Worker, int64, error)
	UpdateStatus(ctx context.Context, id int64, status uint8) (int64, error)
	ValidationByName(ctx context.Context, name string) (bool, error)
	FindByName(ctx context.Context, name string) (domain.Worker, error)

	// Execute 推送消息到Kafka
	Execute(ctx context.Context, req domain.Execute) error
}