Documentation
¶
Index ¶
- type Fake
- func (f *Fake) Client() workflows.Workflow
- func (f *Fake) Init() error
- func (f *Fake) RegisterGrpcServer(grpcServer *grpc.Server)
- func (f *Fake) Run(ctx context.Context) error
- func (f *Fake) WaitForReady(ctx context.Context) error
- func (f *Fake) WithClient(clientFn func() workflows.Workflow) *Fake
- func (f *Fake) WithInit(initFn func() error) *Fake
- func (f *Fake) WithRegisterGrpcServer(registerGrpcServerFn func(grpcServer *grpc.Server)) *Fake
- func (f *Fake) WithRun(runFn func(ctx context.Context) error) *Fake
- func (f *Fake) WithWaitForReady(waitForReadyFn func(ctx context.Context) error) *Fake
- type FakeClient
- func (f *FakeClient) Close() error
- func (f *FakeClient) Get(ctx context.Context, req *workflows.GetRequest) (*workflows.StateResponse, error)
- func (f *FakeClient) Init(metadata workflows.Metadata) error
- func (f *FakeClient) Pause(ctx context.Context, req *workflows.PauseRequest) error
- func (f *FakeClient) Purge(ctx context.Context, req *workflows.PurgeRequest) error
- func (f *FakeClient) RaiseEvent(ctx context.Context, req *workflows.RaiseEventRequest) error
- func (f *FakeClient) Resume(ctx context.Context, req *workflows.ResumeRequest) error
- func (f *FakeClient) Start(ctx context.Context, req *workflows.StartRequest) (*workflows.StartResponse, error)
- func (f *FakeClient) Terminate(ctx context.Context, req *workflows.TerminateRequest) error
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 (*Fake) RegisterGrpcServer ¶
func (*Fake) WithRegisterGrpcServer ¶
type FakeClient ¶
type FakeClient struct {
// contains filtered or unexported fields
}
func (*FakeClient) Close ¶
func (f *FakeClient) Close() error
func (*FakeClient) Get ¶
func (f *FakeClient) Get(ctx context.Context, req *workflows.GetRequest) (*workflows.StateResponse, error)
func (*FakeClient) Pause ¶
func (f *FakeClient) Pause(ctx context.Context, req *workflows.PauseRequest) error
func (*FakeClient) Purge ¶
func (f *FakeClient) Purge(ctx context.Context, req *workflows.PurgeRequest) error
func (*FakeClient) RaiseEvent ¶
func (f *FakeClient) RaiseEvent(ctx context.Context, req *workflows.RaiseEventRequest) error
func (*FakeClient) Resume ¶
func (f *FakeClient) Resume(ctx context.Context, req *workflows.ResumeRequest) error
func (*FakeClient) Start ¶
func (f *FakeClient) Start(ctx context.Context, req *workflows.StartRequest) (*workflows.StartResponse, error)
func (*FakeClient) Terminate ¶
func (f *FakeClient) Terminate(ctx context.Context, req *workflows.TerminateRequest) error
Click to show internal directories.
Click to hide internal directories.