Help us shape the future of Go! Take the 2026 Go Developer Survey

fake

package
v1.19.0 Latest Latest
Warning

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

 Go to latest Published: Oct 22, 2026 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Fake 

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

func New 

func New() *Fake

func (*Fake) ActivateMCPServers added in v1.18.0 

func (f *Fake) ActivateMCPServers(ctx context.Context) error

func (*Fake) ActivityActorType 

func (f *Fake) ActivityActorType() string

func (*Fake) Client 

func (f *Fake) Client() backend.TaskHubClient

func (*Fake) EnsureActorsRegistered added in v1.18.0 

func (f *Fake) EnsureActorsRegistered(_ context.Context) error

func (*Fake) InProcessExecutor added in v1.18.0 

func (f *Fake) InProcessExecutor() *inprocess.Executor

func (*Fake) Init 

func (f *Fake) Init() error

func (*Fake) RegisterGrpcServer 

func (f *Fake) RegisterGrpcServer(grpcServer *grpc.Server)

func (*Fake) RegisterMCPServer added in v1.18.0 

func (f *Fake) RegisterMCPServer(_ context.Context, _ mcpserverapi.MCPServer, _ *compstore.ComponentStore, _ security.Handler) error

func (*Fake) Run 

func (f *Fake) Run(ctx context.Context) error

func (*Fake) RuntimeMetadata added in v1.16.0 

func (f *Fake) RuntimeMetadata() *runtimev1pb.MetadataWorkflows

func (*Fake) UnregisterMCPServer added in v1.18.0 

func (f *Fake) UnregisterMCPServer(_ string)

func (*Fake) WaitForReady 

func (f *Fake) WaitForReady(ctx context.Context) error

func (*Fake) WithClient 

func (f *Fake) WithClient(clientFn func() backend.TaskHubClient) *Fake

func (*Fake) WithInit 

func (f *Fake) WithInit(initFn func() error) *Fake

func (*Fake) WithRegisterGrpcServer 

func (f *Fake) WithRegisterGrpcServer(registerGrpcServerFn func(grpcServer *grpc.Server)) *Fake

func (*Fake) WithRun 

func (f *Fake) WithRun(runFn func(ctx context.Context) error) *Fake

func (*Fake) WithRuntimeMetadata added in v1.16.0 

func (f *Fake) WithRuntimeMetadata(runtimeMetadataFn func() *runtimev1pb.MetadataWorkflows) *Fake

func (*Fake) WithWaitForReady 

func (f *Fake) WithWaitForReady(waitForReadyFn func(ctx context.Context) error) *Fake

func (*Fake) WorkflowActorType added in v1.18.0 

func (f *Fake) WorkflowActorType() string

type FakeClient 

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

func NewClient 

func NewClient() *FakeClient

func (*FakeClient) FetchWorkflowMetadata added in v1.19.0 

func (f *FakeClient) FetchWorkflowMetadata(ctx context.Context, id api.InstanceID, opts ...api.FetchWorkflowMetadataOptions) (*backend.WorkflowMetadata, error)

func (*FakeClient) PurgeWorkflowState added in v1.19.0 

func (f *FakeClient) PurgeWorkflowState(ctx context.Context, id api.InstanceID, opts ...api.PurgeOptions) error

func (*FakeClient) RaiseEvent 

func (f *FakeClient) RaiseEvent(ctx context.Context, id api.InstanceID, eventName string, opts ...api.RaiseEventOptions) error

func (*FakeClient) RerunWorkflowFromEvent added in v1.19.0 

func (f *FakeClient) RerunWorkflowFromEvent(ctx context.Context, source api.InstanceID, eventID uint32, opts ...api.RerunOptions) (api.InstanceID, error)

func (*FakeClient) ResumeWorkflow added in v1.19.0 

func (f *FakeClient) ResumeWorkflow(ctx context.Context, id api.InstanceID, reason string, opts ...api.ResumeOptions) error

func (*FakeClient) ScheduleNewWorkflow added in v1.19.0 

func (f *FakeClient) ScheduleNewWorkflow(ctx context.Context, workflow any, opts ...api.NewWorkflowOptions) (api.InstanceID, error)

func (*FakeClient) SuspendWorkflow added in v1.19.0 

func (f *FakeClient) SuspendWorkflow(ctx context.Context, id api.InstanceID, reason string, opts ...api.SuspendOptions) error

func (*FakeClient) TerminateWorkflow added in v1.19.0 

func (f *FakeClient) TerminateWorkflow(ctx context.Context, id api.InstanceID, opts ...api.TerminateOptions) error

func (*FakeClient) WaitForWorkflowCompletion added in v1.19.0 

func (f *FakeClient) WaitForWorkflowCompletion(ctx context.Context, id api.InstanceID, opts ...api.FetchWorkflowMetadataOptions) (*backend.WorkflowMetadata, error)

func (*FakeClient) WaitForWorkflowStart added in v1.19.0 

func (f *FakeClient) WaitForWorkflowStart(ctx context.Context, id api.InstanceID, opts ...api.FetchWorkflowMetadataOptions) (*backend.WorkflowMetadata, error)

func (*FakeClient) WithFetchWorkflowMetadata added in v1.19.0 

func (f *FakeClient) WithFetchWorkflowMetadata(fn func(ctx context.Context, id api.InstanceID, opts ...api.FetchWorkflowMetadataOptions) (*backend.WorkflowMetadata, error)) *FakeClient

func (*FakeClient) WithPurgeWorkflowState added in v1.19.0 

func (f *FakeClient) WithPurgeWorkflowState(fn func(ctx context.Context, id api.InstanceID, opts ...api.PurgeOptions) error) *FakeClient

func (*FakeClient) WithRaiseEvent 

func (f *FakeClient) WithRaiseEvent(fn func(ctx context.Context, id api.InstanceID, eventName string, opts ...api.RaiseEventOptions) error) *FakeClient

func (*FakeClient) WithRerunWorkflowFromEvent added in v1.19.0 

func (f *FakeClient) WithRerunWorkflowFromEvent(fn func(ctx context.Context, source api.InstanceID, eventID uint32, opts ...api.RerunOptions) (api.InstanceID, error)) *FakeClient

func (*FakeClient) WithResumeWorkflow added in v1.19.0 

func (f *FakeClient) WithResumeWorkflow(fn func(ctx context.Context, id api.InstanceID, reason string, opts ...api.ResumeOptions) error) *FakeClient

func (*FakeClient) WithScheduleNewWorkflow added in v1.19.0 

func (f *FakeClient) WithScheduleNewWorkflow(fn func(ctx context.Context, workflow any, opts ...api.NewWorkflowOptions) (api.InstanceID, error)) *FakeClient

func (*FakeClient) WithSuspendWorkflow added in v1.19.0 

func (f *FakeClient) WithSuspendWorkflow(fn func(ctx context.Context, id api.InstanceID, reason string, opts ...api.SuspendOptions) error) *FakeClient

func (*FakeClient) WithTerminateWorkflow added in v1.19.0 

func (f *FakeClient) WithTerminateWorkflow(fn func(ctx context.Context, id api.InstanceID, opts ...api.TerminateOptions) error) *FakeClient

func (*FakeClient) WithWaitForWorkflowCompletion added in v1.19.0 

func (f *FakeClient) WithWaitForWorkflowCompletion(fn func(ctx context.Context, id api.InstanceID, opts ...api.FetchWorkflowMetadataOptions) (*backend.WorkflowMetadata, error)) *FakeClient

func (*FakeClient) WithWaitForWorkflowStart added in v1.19.0 

func (f *FakeClient) WithWaitForWorkflowStart(fn func(ctx context.Context, id api.InstanceID, opts ...api.FetchWorkflowMetadataOptions) (*backend.WorkflowMetadata, error)) *FakeClient

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.