v1

package
v0.72.0-alpha.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 8, 2025 License: MIT Imports: 27 Imported by: 0

Documentation

Index

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) PutWorkflow 

func (a *AdminServiceImpl) PutWorkflow(ctx context.Context, req *contracts.CreateWorkflowVersionRequest) (*contracts.CreateWorkflowVersionResponse, 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 WithAnalytics added in v0.71.7 

func WithAnalytics(a analytics.Analytics) AdminServiceOpt

func WithEntitlementsRepository 

func WithEntitlementsRepository(r repository.EntitlementsRepository) AdminServiceOpt

func WithLocalDispatcher added in v0.78.0 

func WithLocalDispatcher(d *dispatcher.DispatcherImpl) AdminServiceOpt

func WithLocalScheduler added in v0.78.0 

func WithLocalScheduler(s *scheduler.Scheduler) AdminServiceOpt

func WithLogger added in v0.78.0 

func WithLogger(l *zerolog.Logger) AdminServiceOpt

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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.