executionsdk

Documentation

Index

• type Backend
  • func NewBackend(appFactory *cosmos.AppFactory, serviceBack *servicesdk.Backend, ...) *Backend
  • func (s *Backend) Create(request cosmostypes.Request, msg msgCreateExecution) (*execution.Execution, error)
  • func (s *Backend) Get(request cosmostypes.Request, hash hash.Hash) (*execution.Execution, error)
  • func (s *Backend) List(request cosmostypes.Request) ([]*execution.Execution, error)
  • func (s *Backend) Update(request cosmostypes.Request, msg msgUpdateExecution) (*execution.Execution, error)
• type SDK
  • func New(client *cosmos.Client, serviceSDK *servicesdk.SDK, ...) *SDK
  • func (s *SDK) Create(req *api.CreateExecutionRequest) (*execution.Execution, error)
  • func (s *SDK) Get(hash hash.Hash) (*execution.Execution, error)
  • func (s *SDK) List() ([]*execution.Execution, error)
  • func (s *SDK) Stream(ctx context.Context, req *api.StreamExecutionRequest) (chan *execution.Execution, chan error, error)
  • func (s *SDK) Update(req *api.UpdateExecutionRequest) (*execution.Execution, error)

Types

type Backend

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

Backend is the execution backend.

func NewBackend

func NewBackend(appFactory *cosmos.AppFactory, serviceBack *servicesdk.Backend, instanceBack *instancesdk.Backend, runnerBack *runnersdk.Backend, processBack *processsdk.Backend) *Backend

NewBackend returns the backend of the execution sdk.

func (*Backend) Create

func (s *Backend) Create(request cosmostypes.Request, msg msgCreateExecution) (*execution.Execution, error)

Create creates a new execution from definition.

func (*Backend) Get

func (s *Backend) Get(request cosmostypes.Request, hash hash.Hash) (*execution.Execution, error)

Get returns the execution that matches given hash.

func (*Backend) List

func (s *Backend) List(request cosmostypes.Request) ([]*execution.Execution, error)

List returns all executions.

func (*Backend) Update

func (s *Backend) Update(request cosmostypes.Request, msg msgUpdateExecution) (*execution.Execution, error)

Update updates a new execution from definition.

type SDK

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

SDK is the execution sdk.

func New

func New(client *cosmos.Client, serviceSDK *servicesdk.SDK, instanceSDK *instancesdk.SDK, runnerSDK *runnersdk.SDK) *SDK

New returns the execution sdk.

func (*SDK) Create

func (s *SDK) Create(req *api.CreateExecutionRequest) (*execution.Execution, error)

Create creates a new execution.

func (*SDK) Get

func (s *SDK) Get(hash hash.Hash) (*execution.Execution, error)

Get returns the execution that matches given hash.

func (*SDK) List

func (s *SDK) List() ([]*execution.Execution, error)

List returns all executions.

func (*SDK) Stream

func (s *SDK) Stream(ctx context.Context, req *api.StreamExecutionRequest) (chan *execution.Execution, chan error, error)

Stream returns execution that matches given hash.

func (*SDK) Update

func (s *SDK) Update(req *api.UpdateExecutionRequest) (*execution.Execution, error)

Update updates a execution.