keeper

Documentation

Overview

VM keeper processing messages from handler.

Keeper methods related to data source.

Work with genesis data.

VM and storage related things.

Implementation of Data Source (DS) server.

VM GRPC related functional.

Index

• func ErrNoData(path *ds_grpc.DSAccessPath) *ds_grpc.DSRawResponse
• func GetFreeGas(ctx sdk.Context) sdk.Gas
• func NewContract(address sdk.AccAddress, maxGas sdk.Gas, code []byte, ...) (*vm_grpc.VMContract, sdk.Error)
• func NewDeployRequest(ctx sdk.Context, msg types.MsgDeployModule) (*vm_grpc.VMExecuteRequest, sdk.Error)
• func NewExecuteRequest(ctx sdk.Context, msg types.MsgExecuteScript) (*vm_grpc.VMExecuteRequest, sdk.Error)
• func StartServer(listener net.Listener, dsServer *DSServer) *grpc.Server
• type DSServer
  • func NewDSServer(keeper *Keeper) *DSServer
  • func (server DSServer) GetRaw(_ context.Context, req *ds_grpc.DSAccessPath) (*ds_grpc.DSRawResponse, error)
  • func (server DSServer) IsStarted() bool
  • func (server *DSServer) Logger() log.Logger
  • func (server DSServer) MultiGetRaw(_ context.Context, req *ds_grpc.DSAccessPaths) (*ds_grpc.DSRawResponses, error)
  • func (server *DSServer) SetContext(ctx sdk.Context)
• type Keeper
  • func NewKeeper(storeKey sdk.StoreKey, cdc *amino.Codec, conn *grpc.ClientConn, ...) (keeper Keeper)
  • func (keeper Keeper) CloseConnections()
  • func (keeper Keeper) DeployContract(ctx sdk.Context, msg types.MsgDeployModule) sdk.Error
  • func (keeper Keeper) ExecuteScript(ctx sdk.Context, msg types.MsgExecuteScript) sdk.Error
  • func (keeper Keeper) GetOracleAccessPath(assetCode string) *vm_grpc.VMAccessPath
  • func (keeper Keeper) GetValue(ctx sdk.Context, accessPath *vm_grpc.VMAccessPath) []byte
  • func (keeper Keeper) InitGenesis(ctx sdk.Context, data json.RawMessage)
  • func (Keeper) Logger(ctx sdk.Context) log.Logger
  • func (keeper Keeper) SetDSContext(ctx sdk.Context)
  • func (keeper Keeper) SetValue(ctx sdk.Context, accessPath *vm_grpc.VMAccessPath, value []byte)
  • func (keeper *Keeper) StartDSServer(ctx sdk.Context)
• type VMStorage

Functions

func ErrNoData

func ErrNoData(path *ds_grpc.DSAccessPath) *ds_grpc.DSRawResponse

Error when no data found.

func GetFreeGas

func GetFreeGas(ctx sdk.Context) sdk.Gas

Get free gas from execution context.

func NewContract

func NewContract(address sdk.AccAddress, maxGas sdk.Gas, code []byte, contractType vm_grpc.ContractType, args []*vm_grpc.VMArgs) (*vm_grpc.VMContract, sdk.Error)

Create new contract in grpc format for VM request.

func NewDeployRequest

func NewDeployRequest(ctx sdk.Context, msg types.MsgDeployModule) (*vm_grpc.VMExecuteRequest, sdk.Error)

Create deploy request for VM grpc server.

func NewExecuteRequest

func NewExecuteRequest(ctx sdk.Context, msg types.MsgExecuteScript) (*vm_grpc.VMExecuteRequest, sdk.Error)

Create execute script request for VM grpc server.

func StartServer

func StartServer(listener net.Listener, dsServer *DSServer) *grpc.Server

Start DS server in go routine.

Types

type DSServer

type DSServer struct {
	ds_grpc.UnimplementedDSServiceServer
	// contains filtered or unexported fields
}

Server to catch VM data client requests.

func NewDSServer

func NewDSServer(keeper *Keeper) *DSServer

Creating new DS server.

func (DSServer) GetRaw

func (server DSServer) GetRaw(_ context.Context, req *ds_grpc.DSAccessPath) (*ds_grpc.DSRawResponse, error)

Data source processing request to return value from storage.

func (DSServer) IsStarted

func (server DSServer) IsStarted() bool

Check if server is already in listen mode.

func (*DSServer) Logger

func (server *DSServer) Logger() log.Logger

Server logger.

func (DSServer) MultiGetRaw

func (server DSServer) MultiGetRaw(_ context.Context, req *ds_grpc.DSAccessPaths) (*ds_grpc.DSRawResponses, error)

Data source processing request to return multiplay values form storage.

func (*DSServer) SetContext

func (server *DSServer) SetContext(ctx sdk.Context)

Set server context.

type Keeper

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

VM keeper.

func NewKeeper

func NewKeeper(storeKey sdk.StoreKey, cdc *amino.Codec, conn *grpc.ClientConn, listener net.Listener, config *config.VMConfig) (keeper Keeper)

Initialize VM keeper (include grpc client to VM and grpc server for data store).

func (Keeper) CloseConnections

func (keeper Keeper) CloseConnections()

Stop DS server and close connection to VM.

func (Keeper) DeployContract

func (keeper Keeper) DeployContract(ctx sdk.Context, msg types.MsgDeployModule) sdk.Error

Deploy module.

func (Keeper) ExecuteScript

func (keeper Keeper) ExecuteScript(ctx sdk.Context, msg types.MsgExecuteScript) sdk.Error

Execute script.

func (Keeper) GetOracleAccessPath

func (keeper Keeper) GetOracleAccessPath(assetCode string) *vm_grpc.VMAccessPath

Public get path for oracle price.

func (Keeper) GetValue

func (keeper Keeper) GetValue(ctx sdk.Context, accessPath *vm_grpc.VMAccessPath) []byte

Public get value by path.

func (Keeper) InitGenesis

func (keeper Keeper) InitGenesis(ctx sdk.Context, data json.RawMessage)

Process genesis state and write state.

func (Keeper) Logger

func (Keeper) Logger(ctx sdk.Context) log.Logger

VM keeper logger.

func (Keeper) SetDSContext

func (keeper Keeper) SetDSContext(ctx sdk.Context)

Set DS (data-source) server context.

func (Keeper) SetValue

func (keeper Keeper) SetValue(ctx sdk.Context, accessPath *vm_grpc.VMAccessPath, value []byte)

Public set value.

func (*Keeper) StartDSServer

func (keeper *Keeper) StartDSServer(ctx sdk.Context)

Start Data source (DS) server.

type VMStorage

type VMStorage interface {
	GetOracleAccessPath(assetCode string) *vm_grpc.VMAccessPath
	SetValue(ctx sdk.Context, accessPath *vm_grpc.VMAccessPath, value []byte)
	GetValue(ctx sdk.Context, accessPath *vm_grpc.VMAccessPath) []byte
}

Interface for other keepers to get/set data.