Documentation
¶
Index ¶
- type AdminService
- type AdminServiceImpl
- func (a *AdminServiceImpl) CancelTasks(ctx context.Context, req *contracts.CancelTasksRequest) (*contracts.CancelTasksResponse, error)
- func (a *AdminServiceImpl) ReplayTasks(ctx context.Context, req *contracts.ReplayTasksRequest) (*contracts.ReplayTasksResponse, error)
- func (a *AdminServiceImpl) TriggerWorkflowRun(ctx context.Context, req *contracts.TriggerWorkflowRunRequest) (*contracts.TriggerWorkflowRunResponse, error)
- type AdminServiceOpt
- type AdminServiceOpts
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AdminService ¶
type AdminService interface {
contracts.AdminServiceServer
}
func NewAdminService ¶
func NewAdminService(fs ...AdminServiceOpt) (AdminService, error)
type AdminServiceImpl ¶
type AdminServiceImpl struct {
contracts.UnimplementedAdminServiceServer
// contains filtered or unexported fields
}
func (*AdminServiceImpl) CancelTasks ¶
func (a *AdminServiceImpl) CancelTasks(ctx context.Context, req *contracts.CancelTasksRequest) (*contracts.CancelTasksResponse, error)
func (*AdminServiceImpl) ReplayTasks ¶
func (a *AdminServiceImpl) ReplayTasks(ctx context.Context, req *contracts.ReplayTasksRequest) (*contracts.ReplayTasksResponse, error)
func (*AdminServiceImpl) TriggerWorkflowRun ¶
func (a *AdminServiceImpl) TriggerWorkflowRun(ctx context.Context, req *contracts.TriggerWorkflowRunRequest) (*contracts.TriggerWorkflowRunResponse, error)
type AdminServiceOpt ¶
type AdminServiceOpt func(*AdminServiceOpts)
func WithMessageQueue ¶
func WithMessageQueue(mq msgqueue.MessageQueue) AdminServiceOpt
func WithRepository ¶
func WithRepository(r v1.Repository) AdminServiceOpt
func WithValidator ¶
func WithValidator(v validator.Validator) AdminServiceOpt
type AdminServiceOpts ¶
type AdminServiceOpts struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.