executionsdk

Documentation

Index

• Constants
• func NewModule(k *Keeper) module.AppModule
• type Keeper
  • func NewKeeper(storeKey *cosmostypes.KVStoreKey, serviceKeeper *servicesdk.Keeper, ...) *Keeper
  • func (k *Keeper) Create(request cosmostypes.Request, msg msgCreateExecution) (*execution.Execution, error)
  • func (k *Keeper) Get(request cosmostypes.Request, hash hash.Hash) (*execution.Execution, error)
  • func (k *Keeper) List(request cosmostypes.Request) ([]*execution.Execution, error)
  • func (k *Keeper) 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)

Constants

const ModuleName = "execution"

ModuleName is the name of this module.

Functions

func NewModule

func NewModule(k *Keeper) module.AppModule

NewModule returns the module of this sdk.

Types

type Keeper

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

Keeper holds the logic to read and write data.

func NewKeeper

func NewKeeper(storeKey *cosmostypes.KVStoreKey, serviceKeeper *servicesdk.Keeper, instanceKeeper *instancesdk.Keeper, runnerKeeper *runnersdk.Keeper, processKeeper *processsdk.Keeper) *Keeper

NewKeeper initialize a new keeper.

func (*Keeper) Create

func (k *Keeper) Create(request cosmostypes.Request, msg msgCreateExecution) (*execution.Execution, error)

Create creates a new execution from definition.

func (*Keeper) Get

func (k *Keeper) Get(request cosmostypes.Request, hash hash.Hash) (*execution.Execution, error)

Get returns the execution that matches given hash.

func (*Keeper) List

func (k *Keeper) List(request cosmostypes.Request) ([]*execution.Execution, error)

List returns all executions.

func (*Keeper) Update

func (k *Keeper) 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.