job

type Config struct {
	Enabled      bool
	ServerAddr   string
	AccessToken  string
	Timeout      *durationpb.Duration
	ExecutorIp   string
	ExecutorPort int32
	RegistryKey  string
}

type JobConfig interface {
	GetEnabled() bool
	GetServerAddr() string
	GetAccessToken() string
	GetTimeout() *durationpb.Duration
	GetExecutorIp() string
	GetExecutorPort() int32
	GetRegistryKey() string
}

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

type JobFunc func(ctx context.Context, payload string) (string, error)

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