Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func KeyPrefix(p string) []byte
- func RegisterCodec(cdc *codec.LegacyAmino)
- func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
- func RegisterMsgServer(s grpc1.Server, srv MsgServer)
- func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
- func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
- func RegisterQueryServer(s grpc1.Server, srv QueryServer)
- type AccountKeeper
- type BankKeeper
- type EventTrigger
- func (*EventTrigger) Descriptor() ([]byte, []int)
- func (m *EventTrigger) Marshal() (dAtA []byte, err error)
- func (m *EventTrigger) MarshalTo(dAtA []byte) (int, error)
- func (m *EventTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EventTrigger) ProtoMessage()
- func (m *EventTrigger) Reset()
- func (m *EventTrigger) Size() (n int)
- func (m *EventTrigger) String() string
- func (m *EventTrigger) Unmarshal(dAtA []byte) error
- func (m *EventTrigger) XXX_DiscardUnknown()
- func (m *EventTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EventTrigger) XXX_Merge(src proto.Message)
- func (m *EventTrigger) XXX_Size() int
- func (m *EventTrigger) XXX_Unmarshal(b []byte) error
- type EvmKeeper
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetParams() Params
- func (m *GenesisState) GetPortId() string
- func (m *GenesisState) Marshal() (dAtA []byte, err error)
- func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisState) ProtoMessage()
- func (m *GenesisState) Reset()
- func (m *GenesisState) Size() (n int)
- func (m *GenesisState) String() string
- func (m *GenesisState) Unmarshal(dAtA []byte) error
- func (gs GenesisState) Validate() error
- func (m *GenesisState) XXX_DiscardUnknown()
- func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisState) XXX_Merge(src proto.Message)
- func (m *GenesisState) XXX_Size() int
- func (m *GenesisState) XXX_Unmarshal(b []byte) error
- type Job
- func (*Job) Descriptor() ([]byte, []int)
- func (m *Job) GetDefinition() []byte
- func (m *Job) GetEnforceMEVRelay() bool
- func (m *Job) GetID() string
- func (m *Job) GetIsPayloadModifiable() bool
- func (m *Job) GetOwner() github_com_cosmos_cosmos_sdk_types.AccAddress
- func (m *Job) GetPayload() []byte
- func (m *Job) GetPermissions() Permissions
- func (m *Job) GetRouting() Routing
- func (m *Job) GetTriggers() []*Trigger
- func (m *Job) Marshal() (dAtA []byte, err error)
- func (m *Job) MarshalTo(dAtA []byte) (int, error)
- func (m *Job) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Job) ProtoMessage()
- func (m *Job) Reset()
- func (m *Job) Size() (n int)
- func (m *Job) String() string
- func (m *Job) Unmarshal(dAtA []byte) error
- func (j *Job) ValidateBasic() error
- func (m *Job) XXX_DiscardUnknown()
- func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Job) XXX_Merge(src proto.Message)
- func (m *Job) XXX_Size() int
- func (m *Job) XXX_Unmarshal(b []byte) error
- type Keeper
- type MsgClient
- type MsgCreateJob
- func (*MsgCreateJob) Descriptor() ([]byte, []int)
- func (m *MsgCreateJob) GetJob() *Job
- func (m *MsgCreateJob) GetMetadata() types.MsgMetadata
- func (msg *MsgCreateJob) GetSignBytes() []byte
- func (msg *MsgCreateJob) GetSigners() []sdk.AccAddress
- func (m *MsgCreateJob) Marshal() (dAtA []byte, err error)
- func (m *MsgCreateJob) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCreateJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCreateJob) ProtoMessage()
- func (m *MsgCreateJob) Reset()
- func (msg *MsgCreateJob) Route() string
- func (m *MsgCreateJob) Size() (n int)
- func (m *MsgCreateJob) String() string
- func (msg *MsgCreateJob) Type() string
- func (m *MsgCreateJob) Unmarshal(dAtA []byte) error
- func (msg *MsgCreateJob) ValidateBasic() error
- func (m *MsgCreateJob) XXX_DiscardUnknown()
- func (m *MsgCreateJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCreateJob) XXX_Merge(src proto.Message)
- func (m *MsgCreateJob) XXX_Size() int
- func (m *MsgCreateJob) XXX_Unmarshal(b []byte) error
- type MsgCreateJobResponse
- func (*MsgCreateJobResponse) Descriptor() ([]byte, []int)
- func (m *MsgCreateJobResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgCreateJobResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgCreateJobResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgCreateJobResponse) ProtoMessage()
- func (m *MsgCreateJobResponse) Reset()
- func (m *MsgCreateJobResponse) Size() (n int)
- func (m *MsgCreateJobResponse) String() string
- func (m *MsgCreateJobResponse) Unmarshal(dAtA []byte) error
- func (m *MsgCreateJobResponse) XXX_DiscardUnknown()
- func (m *MsgCreateJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgCreateJobResponse) XXX_Merge(src proto.Message)
- func (m *MsgCreateJobResponse) XXX_Size() int
- func (m *MsgCreateJobResponse) XXX_Unmarshal(b []byte) error
- type MsgExecuteJob
- func (*MsgExecuteJob) Descriptor() ([]byte, []int)
- func (m *MsgExecuteJob) GetJobID() string
- func (m *MsgExecuteJob) GetMetadata() types.MsgMetadata
- func (m *MsgExecuteJob) GetPayload() []byte
- func (msg *MsgExecuteJob) GetSignBytes() []byte
- func (msg *MsgExecuteJob) GetSigners() []sdk.AccAddress
- func (m *MsgExecuteJob) Marshal() (dAtA []byte, err error)
- func (m *MsgExecuteJob) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgExecuteJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgExecuteJob) ProtoMessage()
- func (m *MsgExecuteJob) Reset()
- func (msg *MsgExecuteJob) Route() string
- func (m *MsgExecuteJob) Size() (n int)
- func (m *MsgExecuteJob) String() string
- func (msg *MsgExecuteJob) Type() string
- func (m *MsgExecuteJob) Unmarshal(dAtA []byte) error
- func (msg *MsgExecuteJob) ValidateBasic() error
- func (m *MsgExecuteJob) XXX_DiscardUnknown()
- func (m *MsgExecuteJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgExecuteJob) XXX_Merge(src proto.Message)
- func (m *MsgExecuteJob) XXX_Size() int
- func (m *MsgExecuteJob) XXX_Unmarshal(b []byte) error
- type MsgExecuteJobResponse
- func (*MsgExecuteJobResponse) Descriptor() ([]byte, []int)
- func (m *MsgExecuteJobResponse) GetMessageID() uint64
- func (m *MsgExecuteJobResponse) Marshal() (dAtA []byte, err error)
- func (m *MsgExecuteJobResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *MsgExecuteJobResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MsgExecuteJobResponse) ProtoMessage()
- func (m *MsgExecuteJobResponse) Reset()
- func (m *MsgExecuteJobResponse) Size() (n int)
- func (m *MsgExecuteJobResponse) String() string
- func (m *MsgExecuteJobResponse) Unmarshal(dAtA []byte) error
- func (m *MsgExecuteJobResponse) XXX_DiscardUnknown()
- func (m *MsgExecuteJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MsgExecuteJobResponse) XXX_Merge(src proto.Message)
- func (m *MsgExecuteJobResponse) XXX_Size() int
- func (m *MsgExecuteJobResponse) XXX_Unmarshal(b []byte) error
- type MsgServer
- type NoData
- func (*NoData) Descriptor() ([]byte, []int)
- func (m *NoData) Marshal() (dAtA []byte, err error)
- func (m *NoData) MarshalTo(dAtA []byte) (int, error)
- func (m *NoData) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NoData) ProtoMessage()
- func (m *NoData) Reset()
- func (m *NoData) Size() (n int)
- func (m *NoData) String() string
- func (m *NoData) Unmarshal(dAtA []byte) error
- func (m *NoData) XXX_DiscardUnknown()
- func (m *NoData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NoData) XXX_Merge(src proto.Message)
- func (m *NoData) XXX_Size() int
- func (m *NoData) XXX_Unmarshal(b []byte) error
- type OnMessageProcessor
- type Params
- func (*Params) Descriptor() ([]byte, []int)
- func (m *Params) Marshal() (dAtA []byte, err error)
- func (m *Params) MarshalTo(dAtA []byte) (int, error)
- func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs
- func (*Params) ProtoMessage()
- func (m *Params) Reset()
- func (m *Params) Size() (n int)
- func (p Params) String() string
- func (m *Params) Unmarshal(dAtA []byte) error
- func (p Params) Validate() error
- func (m *Params) XXX_DiscardUnknown()
- func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Params) XXX_Merge(src proto.Message)
- func (m *Params) XXX_Size() int
- func (m *Params) XXX_Unmarshal(b []byte) error
- type Permissions
- func (*Permissions) Descriptor() ([]byte, []int)
- func (m *Permissions) GetBlacklist() []*Runner
- func (m *Permissions) GetWhitelist() []*Runner
- func (m *Permissions) Marshal() (dAtA []byte, err error)
- func (m *Permissions) MarshalTo(dAtA []byte) (int, error)
- func (m *Permissions) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Permissions) ProtoMessage()
- func (m *Permissions) Reset()
- func (m *Permissions) Size() (n int)
- func (m *Permissions) String() string
- func (m *Permissions) Unmarshal(dAtA []byte) error
- func (p *Permissions) ValidateBasic() error
- func (m *Permissions) XXX_DiscardUnknown()
- func (m *Permissions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Permissions) XXX_Merge(src proto.Message)
- func (m *Permissions) XXX_Size() int
- func (m *Permissions) XXX_Unmarshal(b []byte) error
- type QueryClient
- type QueryGetJobByIDRequest
- func (*QueryGetJobByIDRequest) Descriptor() ([]byte, []int)
- func (m *QueryGetJobByIDRequest) GetJobID() string
- func (m *QueryGetJobByIDRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryGetJobByIDRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetJobByIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetJobByIDRequest) ProtoMessage()
- func (m *QueryGetJobByIDRequest) Reset()
- func (m *QueryGetJobByIDRequest) Size() (n int)
- func (m *QueryGetJobByIDRequest) String() string
- func (m *QueryGetJobByIDRequest) Unmarshal(dAtA []byte) error
- func (m *QueryGetJobByIDRequest) XXX_DiscardUnknown()
- func (m *QueryGetJobByIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetJobByIDRequest) XXX_Merge(src proto.Message)
- func (m *QueryGetJobByIDRequest) XXX_Size() int
- func (m *QueryGetJobByIDRequest) XXX_Unmarshal(b []byte) error
- type QueryGetJobByIDResponse
- func (*QueryGetJobByIDResponse) Descriptor() ([]byte, []int)
- func (m *QueryGetJobByIDResponse) GetJob() *Job
- func (m *QueryGetJobByIDResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryGetJobByIDResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryGetJobByIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryGetJobByIDResponse) ProtoMessage()
- func (m *QueryGetJobByIDResponse) Reset()
- func (m *QueryGetJobByIDResponse) Size() (n int)
- func (m *QueryGetJobByIDResponse) String() string
- func (m *QueryGetJobByIDResponse) Unmarshal(dAtA []byte) error
- func (m *QueryGetJobByIDResponse) XXX_DiscardUnknown()
- func (m *QueryGetJobByIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryGetJobByIDResponse) XXX_Merge(src proto.Message)
- func (m *QueryGetJobByIDResponse) XXX_Size() int
- func (m *QueryGetJobByIDResponse) XXX_Unmarshal(b []byte) error
- type QueryParamsRequest
- func (*QueryParamsRequest) Descriptor() ([]byte, []int)
- func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryParamsRequest) ProtoMessage()
- func (m *QueryParamsRequest) Reset()
- func (m *QueryParamsRequest) Size() (n int)
- func (m *QueryParamsRequest) String() string
- func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryParamsRequest) XXX_DiscardUnknown()
- func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryParamsRequest) XXX_Merge(src proto.Message)
- func (m *QueryParamsRequest) XXX_Size() int
- func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error
- type QueryParamsResponse
- func (*QueryParamsResponse) Descriptor() ([]byte, []int)
- func (m *QueryParamsResponse) GetParams() Params
- func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryParamsResponse) ProtoMessage()
- func (m *QueryParamsResponse) Reset()
- func (m *QueryParamsResponse) Size() (n int)
- func (m *QueryParamsResponse) String() string
- func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryParamsResponse) XXX_DiscardUnknown()
- func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryParamsResponse) XXX_Merge(src proto.Message)
- func (m *QueryParamsResponse) XXX_Size() int
- func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type Routing
- func (*Routing) Descriptor() ([]byte, []int)
- func (m *Routing) GetChainReferenceID() string
- func (m *Routing) GetChainType() string
- func (m *Routing) Marshal() (dAtA []byte, err error)
- func (m *Routing) MarshalTo(dAtA []byte) (int, error)
- func (m *Routing) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Routing) ProtoMessage()
- func (m *Routing) Reset()
- func (m *Routing) Size() (n int)
- func (m *Routing) String() string
- func (m *Routing) Unmarshal(dAtA []byte) error
- func (m *Routing) XXX_DiscardUnknown()
- func (m *Routing) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Routing) XXX_Merge(src proto.Message)
- func (m *Routing) XXX_Size() int
- func (m *Routing) XXX_Unmarshal(b []byte) error
- type Runner
- func (*Runner) Descriptor() ([]byte, []int)
- func (m *Runner) GetAddress() []byte
- func (m *Runner) GetChainReferenceID() string
- func (m *Runner) GetChainType() string
- func (m *Runner) Marshal() (dAtA []byte, err error)
- func (m *Runner) MarshalTo(dAtA []byte) (int, error)
- func (m *Runner) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Runner) ProtoMessage()
- func (m *Runner) Reset()
- func (m *Runner) Size() (n int)
- func (m *Runner) String() string
- func (m *Runner) Unmarshal(dAtA []byte) error
- func (m *Runner) XXX_DiscardUnknown()
- func (m *Runner) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Runner) XXX_Merge(src proto.Message)
- func (m *Runner) XXX_Size() int
- func (m *Runner) XXX_Unmarshal(b []byte) error
- type ScheduleTrigger
- func (*ScheduleTrigger) Descriptor() ([]byte, []int)
- func (m *ScheduleTrigger) Marshal() (dAtA []byte, err error)
- func (m *ScheduleTrigger) MarshalTo(dAtA []byte) (int, error)
- func (m *ScheduleTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ScheduleTrigger) ProtoMessage()
- func (m *ScheduleTrigger) Reset()
- func (m *ScheduleTrigger) Size() (n int)
- func (m *ScheduleTrigger) String() string
- func (m *ScheduleTrigger) Unmarshal(dAtA []byte) error
- func (m *ScheduleTrigger) XXX_DiscardUnknown()
- func (m *ScheduleTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ScheduleTrigger) XXX_Merge(src proto.Message)
- func (m *ScheduleTrigger) XXX_Size() int
- func (m *ScheduleTrigger) XXX_Unmarshal(b []byte) error
- type SchedulerPacketData
- func (*SchedulerPacketData) Descriptor() ([]byte, []int)
- func (m *SchedulerPacketData) GetNoData() *NoData
- func (m *SchedulerPacketData) GetPacket() isSchedulerPacketData_Packet
- func (m *SchedulerPacketData) Marshal() (dAtA []byte, err error)
- func (m *SchedulerPacketData) MarshalTo(dAtA []byte) (int, error)
- func (m *SchedulerPacketData) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*SchedulerPacketData) ProtoMessage()
- func (m *SchedulerPacketData) Reset()
- func (m *SchedulerPacketData) Size() (n int)
- func (m *SchedulerPacketData) String() string
- func (m *SchedulerPacketData) Unmarshal(dAtA []byte) error
- func (m *SchedulerPacketData) XXX_DiscardUnknown()
- func (m *SchedulerPacketData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SchedulerPacketData) XXX_Merge(src proto.Message)
- func (*SchedulerPacketData) XXX_OneofWrappers() []interface{}
- func (m *SchedulerPacketData) XXX_Size() int
- func (m *SchedulerPacketData) XXX_Unmarshal(b []byte) error
- type SchedulerPacketData_NoData
- type Trigger
- func (*Trigger) Descriptor() ([]byte, []int)
- func (m *Trigger) GetEvent() *EventTrigger
- func (m *Trigger) GetSchedule() *ScheduleTrigger
- func (m *Trigger) GetTrigger() isTrigger_Trigger
- func (m *Trigger) Marshal() (dAtA []byte, err error)
- func (m *Trigger) MarshalTo(dAtA []byte) (int, error)
- func (m *Trigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Trigger) ProtoMessage()
- func (m *Trigger) Reset()
- func (m *Trigger) Size() (n int)
- func (m *Trigger) String() string
- func (m *Trigger) Unmarshal(dAtA []byte) error
- func (m *Trigger) XXX_DiscardUnknown()
- func (m *Trigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Trigger) XXX_Merge(src proto.Message)
- func (*Trigger) XXX_OneofWrappers() []interface{}
- func (m *Trigger) XXX_Size() int
- func (m *Trigger) XXX_Unmarshal(b []byte) error
- type Trigger_Event
- type Trigger_Schedule
- type UnimplementedMsgServer
- type UnimplementedQueryServer
- type ValsetKeeper
Constants ¶
const ( EventTypeTimeout = "timeout" AttributeKeyAckSuccess = "success" AttributeKeyAck = "acknowledgement" AttributeKeyAckError = "error" )
IBC events
const ( // ModuleName defines the module name ModuleName = "scheduler" // StoreKey defines the primary module store key StoreKey = ModuleName // RouterKey is the message route for slashing RouterKey = ModuleName // QuerierRoute defines the module's query routing key QuerierRoute = ModuleName // MemStoreKey defines the in-memory store key MemStoreKey = "mem_scheduler" // Version defines the current version the IBC module supports Version = "scheduler-1" // PortID is the default port id that module binds to PortID = "scheduler" )
const (
CronchainDenom = "grain"
)
const DefaultIndex uint64 = 1
DefaultIndex is the default capability global index
const JobAddressLength = 32
const JobIDMaxLen = 32
const TypeMsgCreateJob = "create_job"
const TypeMsgExecuteJob = "execute_job"
Variables ¶
var ( Amino = codec.NewLegacyAmino() ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry()) )
var ( ErrSample = sdkerrors.Register(ModuleName, 1100, "sample error") ErrInvalidPacketTimeout = sdkerrors.Register(ModuleName, 1500, "invalid packet timeout") ErrInvalidVersion = sdkerrors.Register(ModuleName, 1501, "invalid version") ErrJobWithIDAlreadyExists = sdkerrors.Register(ModuleName, 1200, "job with id already exists") ErrJobNotFound = sdkerrors.Register(ModuleName, 1201, "job not found") ErrInvalid = sdkerrors.Register(ModuleName, 1202, "invalid") ErrCannotModifyJobPayload = sdkerrors.Register(ModuleName, 1203, "cannot modify job's payload") ErrWasmExecuteMessageNotValid = sdkerrors.Register(ModuleName, 1204, "wasm message is not valid") )
x/scheduler module sentinel errors
var ( ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthJob = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowJob = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupJob = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthPacket = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPacket = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupPacket = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthParams = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowParams = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var ( ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowTx = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group") )
var PortKey = KeyPrefix("scheduler-port-")
PortKey defines the key to store the port ID in store
Functions ¶
func RegisterCodec ¶
func RegisterCodec(cdc *codec.LegacyAmino)
func RegisterInterfaces ¶
func RegisterInterfaces(registry cdctypes.InterfaceRegistry)
func RegisterMsgServer ¶
func RegisterQueryHandler ¶
RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterQueryHandlerClient ¶
func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.
func RegisterQueryHandlerFromEndpoint ¶
func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterQueryHandlerServer ¶
func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc1.Server, srv QueryServer)
Types ¶
type AccountKeeper ¶
type AccountKeeper interface { GetAccount(ctx context.Context, addr sdk.AccAddress) sdk.AccountI NewAccountWithAddress(ctx context.Context, addr sdk.AccAddress) sdk.AccountI HasAccount(ctx context.Context, addr sdk.AccAddress) bool SetAccount(ctx context.Context, acc sdk.AccountI) }
AccountKeeper defines the expected account keeper used for simulations (noalias)
type BankKeeper ¶
BankKeeper defines the expected interface needed to retrieve account balances.
type EventTrigger ¶ added in v0.10.0
type EventTrigger struct { }
func (*EventTrigger) Descriptor ¶ added in v0.10.0
func (*EventTrigger) Descriptor() ([]byte, []int)
func (*EventTrigger) Marshal ¶ added in v0.10.0
func (m *EventTrigger) Marshal() (dAtA []byte, err error)
func (*EventTrigger) MarshalTo ¶ added in v0.10.0
func (m *EventTrigger) MarshalTo(dAtA []byte) (int, error)
func (*EventTrigger) MarshalToSizedBuffer ¶ added in v0.10.0
func (m *EventTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EventTrigger) ProtoMessage ¶ added in v0.10.0
func (*EventTrigger) ProtoMessage()
func (*EventTrigger) Reset ¶ added in v0.10.0
func (m *EventTrigger) Reset()
func (*EventTrigger) Size ¶ added in v0.10.0
func (m *EventTrigger) Size() (n int)
func (*EventTrigger) String ¶ added in v0.10.0
func (m *EventTrigger) String() string
func (*EventTrigger) Unmarshal ¶ added in v0.10.0
func (m *EventTrigger) Unmarshal(dAtA []byte) error
func (*EventTrigger) XXX_DiscardUnknown ¶ added in v0.10.0
func (m *EventTrigger) XXX_DiscardUnknown()
func (*EventTrigger) XXX_Marshal ¶ added in v0.10.0
func (m *EventTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EventTrigger) XXX_Merge ¶ added in v0.10.0
func (m *EventTrigger) XXX_Merge(src proto.Message)
func (*EventTrigger) XXX_Size ¶ added in v0.10.0
func (m *EventTrigger) XXX_Size() int
func (*EventTrigger) XXX_Unmarshal ¶ added in v0.10.0
func (m *EventTrigger) XXX_Unmarshal(b []byte) error
type EvmKeeper ¶ added in v1.2.0
type EvmKeeper interface { PreJobExecution(ctx context.Context, job *Job) error PickValidatorForMessage(ctx context.Context, chainReferenceID string, req *xchain.JobRequirements) (string, error) }
EvmKeeper defines the expected interface for interacting with the evm module
type GenesisState ¶
type GenesisState struct { Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"` PortId string `protobuf:"bytes,2,opt,name=port_id,json=portId,proto3" json:"port_id,omitempty"` }
GenesisState defines the scheduler module's genesis state.
func DefaultGenesis ¶
func DefaultGenesis() *GenesisState
DefaultGenesis returns the default Capability genesis state
func (*GenesisState) Descriptor ¶
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) GetParams ¶
func (m *GenesisState) GetParams() Params
func (*GenesisState) GetPortId ¶
func (m *GenesisState) GetPortId() string
func (*GenesisState) Marshal ¶
func (m *GenesisState) Marshal() (dAtA []byte, err error)
func (*GenesisState) MarshalToSizedBuffer ¶
func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisState) ProtoMessage ¶
func (*GenesisState) ProtoMessage()
func (*GenesisState) Reset ¶
func (m *GenesisState) Reset()
func (*GenesisState) Size ¶
func (m *GenesisState) Size() (n int)
func (*GenesisState) String ¶
func (m *GenesisState) String() string
func (*GenesisState) Unmarshal ¶
func (m *GenesisState) Unmarshal(dAtA []byte) error
func (GenesisState) Validate ¶
func (gs GenesisState) Validate() error
Validate performs basic genesis state validation returning an error upon any failure.
func (*GenesisState) XXX_DiscardUnknown ¶
func (m *GenesisState) XXX_DiscardUnknown()
func (*GenesisState) XXX_Marshal ¶
func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisState) XXX_Merge ¶
func (m *GenesisState) XXX_Merge(src proto.Message)
func (*GenesisState) XXX_Size ¶
func (m *GenesisState) XXX_Size() int
func (*GenesisState) XXX_Unmarshal ¶
func (m *GenesisState) XXX_Unmarshal(b []byte) error
type Job ¶ added in v0.10.0
type Job struct { // chosen by the owner ID string `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"` Owner github_com_cosmos_cosmos_sdk_types.AccAddress `protobuf:"bytes,2,opt,name=owner,proto3,casttype=github.com/cosmos/cosmos-sdk/types.AccAddress" json:"owner,omitempty"` Routing Routing `protobuf:"bytes,3,opt,name=routing,proto3" json:"routing"` // this is the job definition. It is something arbitrary as it's different for // every chain. Definition []byte `protobuf:"bytes,5,opt,name=definition,proto3" json:"definition,omitempty"` // this is the payload for the job Payload []byte `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"` IsPayloadModifiable bool `protobuf:"varint,7,opt,name=isPayloadModifiable,proto3" json:"isPayloadModifiable,omitempty"` Permissions Permissions `protobuf:"bytes,8,opt,name=permissions,proto3" json:"permissions"` Triggers []*Trigger `protobuf:"bytes,9,rep,name=triggers,proto3" json:"triggers,omitempty"` EnforceMEVRelay bool `protobuf:"varint,11,opt,name=enforceMEVRelay,proto3" json:"enforceMEVRelay,omitempty"` }
func (*Job) Descriptor ¶ added in v0.10.0
func (*Job) GetDefinition ¶ added in v0.10.0
func (*Job) GetEnforceMEVRelay ¶ added in v1.7.1
func (*Job) GetIsPayloadModifiable ¶ added in v0.10.0
func (*Job) GetOwner ¶ added in v0.10.0
func (m *Job) GetOwner() github_com_cosmos_cosmos_sdk_types.AccAddress
func (*Job) GetPayload ¶ added in v0.10.0
func (*Job) GetPermissions ¶ added in v0.10.0
func (m *Job) GetPermissions() Permissions
func (*Job) GetRouting ¶ added in v0.10.0
func (*Job) GetTriggers ¶ added in v0.10.0
func (*Job) MarshalToSizedBuffer ¶ added in v0.10.0
func (*Job) ProtoMessage ¶ added in v0.10.0
func (*Job) ProtoMessage()
func (*Job) ValidateBasic ¶ added in v0.10.0
func (*Job) XXX_DiscardUnknown ¶ added in v0.10.0
func (m *Job) XXX_DiscardUnknown()
func (*Job) XXX_Marshal ¶ added in v0.10.0
func (*Job) XXX_Unmarshal ¶ added in v0.10.0
type Keeper ¶ added in v1.4.0
type Keeper interface { AddNewJob(ctx context.Context, job *Job) error GetAccount(ctx context.Context, addr sdk.AccAddress) types.AccountI GetJob(ctx context.Context, jobID string) (*Job, error) Logger(ctx context.Context) log.Logger PreJobExecution(ctx context.Context, job *Job) error ScheduleNow(ctx context.Context, jobID string, in []byte, senderAddress sdk.AccAddress, contractAddress sdk.AccAddress) (uint64, error) ExecuteJob(ctx context.Context, jobID string, payload []byte, senderAddress sdk.AccAddress, contractAddr sdk.AccAddress) (uint64, error) }
type MsgClient ¶
type MsgClient interface { CreateJob(ctx context.Context, in *MsgCreateJob, opts ...grpc.CallOption) (*MsgCreateJobResponse, error) ExecuteJob(ctx context.Context, in *MsgExecuteJob, opts ...grpc.CallOption) (*MsgExecuteJobResponse, error) }
MsgClient is the client API for Msg service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMsgClient ¶
func NewMsgClient(cc grpc1.ClientConn) MsgClient
type MsgCreateJob ¶ added in v0.10.0
type MsgCreateJob struct { Job *Job `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"` Metadata types.MsgMetadata `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata"` }
func NewMsgCreateJob ¶ added in v0.10.0
func NewMsgCreateJob(creator string) *MsgCreateJob
func (*MsgCreateJob) Descriptor ¶ added in v0.10.0
func (*MsgCreateJob) Descriptor() ([]byte, []int)
func (*MsgCreateJob) GetJob ¶ added in v0.10.0
func (m *MsgCreateJob) GetJob() *Job
func (*MsgCreateJob) GetMetadata ¶ added in v1.10.0
func (m *MsgCreateJob) GetMetadata() types.MsgMetadata
func (*MsgCreateJob) GetSignBytes ¶ added in v0.10.0
func (msg *MsgCreateJob) GetSignBytes() []byte
func (*MsgCreateJob) GetSigners ¶ added in v0.10.0
func (msg *MsgCreateJob) GetSigners() []sdk.AccAddress
func (*MsgCreateJob) Marshal ¶ added in v0.10.0
func (m *MsgCreateJob) Marshal() (dAtA []byte, err error)
func (*MsgCreateJob) MarshalTo ¶ added in v0.10.0
func (m *MsgCreateJob) MarshalTo(dAtA []byte) (int, error)
func (*MsgCreateJob) MarshalToSizedBuffer ¶ added in v0.10.0
func (m *MsgCreateJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCreateJob) ProtoMessage ¶ added in v0.10.0
func (*MsgCreateJob) ProtoMessage()
func (*MsgCreateJob) Reset ¶ added in v0.10.0
func (m *MsgCreateJob) Reset()
func (*MsgCreateJob) Route ¶ added in v0.10.0
func (msg *MsgCreateJob) Route() string
func (*MsgCreateJob) Size ¶ added in v0.10.0
func (m *MsgCreateJob) Size() (n int)
func (*MsgCreateJob) String ¶ added in v0.10.0
func (m *MsgCreateJob) String() string
func (*MsgCreateJob) Type ¶ added in v0.10.0
func (msg *MsgCreateJob) Type() string
func (*MsgCreateJob) Unmarshal ¶ added in v0.10.0
func (m *MsgCreateJob) Unmarshal(dAtA []byte) error
func (*MsgCreateJob) ValidateBasic ¶ added in v0.10.0
func (msg *MsgCreateJob) ValidateBasic() error
func (*MsgCreateJob) XXX_DiscardUnknown ¶ added in v0.10.0
func (m *MsgCreateJob) XXX_DiscardUnknown()
func (*MsgCreateJob) XXX_Marshal ¶ added in v0.10.0
func (m *MsgCreateJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCreateJob) XXX_Merge ¶ added in v0.10.0
func (m *MsgCreateJob) XXX_Merge(src proto.Message)
func (*MsgCreateJob) XXX_Size ¶ added in v0.10.0
func (m *MsgCreateJob) XXX_Size() int
func (*MsgCreateJob) XXX_Unmarshal ¶ added in v0.10.0
func (m *MsgCreateJob) XXX_Unmarshal(b []byte) error
type MsgCreateJobResponse ¶ added in v0.10.0
type MsgCreateJobResponse struct { }
func (*MsgCreateJobResponse) Descriptor ¶ added in v0.10.0
func (*MsgCreateJobResponse) Descriptor() ([]byte, []int)
func (*MsgCreateJobResponse) Marshal ¶ added in v0.10.0
func (m *MsgCreateJobResponse) Marshal() (dAtA []byte, err error)
func (*MsgCreateJobResponse) MarshalTo ¶ added in v0.10.0
func (m *MsgCreateJobResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgCreateJobResponse) MarshalToSizedBuffer ¶ added in v0.10.0
func (m *MsgCreateJobResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgCreateJobResponse) ProtoMessage ¶ added in v0.10.0
func (*MsgCreateJobResponse) ProtoMessage()
func (*MsgCreateJobResponse) Reset ¶ added in v0.10.0
func (m *MsgCreateJobResponse) Reset()
func (*MsgCreateJobResponse) Size ¶ added in v0.10.0
func (m *MsgCreateJobResponse) Size() (n int)
func (*MsgCreateJobResponse) String ¶ added in v0.10.0
func (m *MsgCreateJobResponse) String() string
func (*MsgCreateJobResponse) Unmarshal ¶ added in v0.10.0
func (m *MsgCreateJobResponse) Unmarshal(dAtA []byte) error
func (*MsgCreateJobResponse) XXX_DiscardUnknown ¶ added in v0.10.0
func (m *MsgCreateJobResponse) XXX_DiscardUnknown()
func (*MsgCreateJobResponse) XXX_Marshal ¶ added in v0.10.0
func (m *MsgCreateJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgCreateJobResponse) XXX_Merge ¶ added in v0.10.0
func (m *MsgCreateJobResponse) XXX_Merge(src proto.Message)
func (*MsgCreateJobResponse) XXX_Size ¶ added in v0.10.0
func (m *MsgCreateJobResponse) XXX_Size() int
func (*MsgCreateJobResponse) XXX_Unmarshal ¶ added in v0.10.0
func (m *MsgCreateJobResponse) XXX_Unmarshal(b []byte) error
type MsgExecuteJob ¶ added in v0.10.0
type MsgExecuteJob struct { JobID string `protobuf:"bytes,2,opt,name=jobID,proto3" json:"jobID,omitempty"` Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"` Metadata types.MsgMetadata `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata"` }
func NewMsgExecuteJob ¶ added in v0.10.0
func NewMsgExecuteJob(creator string, jobID string) *MsgExecuteJob
func (*MsgExecuteJob) Descriptor ¶ added in v0.10.0
func (*MsgExecuteJob) Descriptor() ([]byte, []int)
func (*MsgExecuteJob) GetJobID ¶ added in v0.10.0
func (m *MsgExecuteJob) GetJobID() string
func (*MsgExecuteJob) GetMetadata ¶ added in v1.10.0
func (m *MsgExecuteJob) GetMetadata() types.MsgMetadata
func (*MsgExecuteJob) GetPayload ¶ added in v0.10.0
func (m *MsgExecuteJob) GetPayload() []byte
func (*MsgExecuteJob) GetSignBytes ¶ added in v0.10.0
func (msg *MsgExecuteJob) GetSignBytes() []byte
func (*MsgExecuteJob) GetSigners ¶ added in v0.10.0
func (msg *MsgExecuteJob) GetSigners() []sdk.AccAddress
func (*MsgExecuteJob) Marshal ¶ added in v0.10.0
func (m *MsgExecuteJob) Marshal() (dAtA []byte, err error)
func (*MsgExecuteJob) MarshalTo ¶ added in v0.10.0
func (m *MsgExecuteJob) MarshalTo(dAtA []byte) (int, error)
func (*MsgExecuteJob) MarshalToSizedBuffer ¶ added in v0.10.0
func (m *MsgExecuteJob) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgExecuteJob) ProtoMessage ¶ added in v0.10.0
func (*MsgExecuteJob) ProtoMessage()
func (*MsgExecuteJob) Reset ¶ added in v0.10.0
func (m *MsgExecuteJob) Reset()
func (*MsgExecuteJob) Route ¶ added in v0.10.0
func (msg *MsgExecuteJob) Route() string
func (*MsgExecuteJob) Size ¶ added in v0.10.0
func (m *MsgExecuteJob) Size() (n int)
func (*MsgExecuteJob) String ¶ added in v0.10.0
func (m *MsgExecuteJob) String() string
func (*MsgExecuteJob) Type ¶ added in v0.10.0
func (msg *MsgExecuteJob) Type() string
func (*MsgExecuteJob) Unmarshal ¶ added in v0.10.0
func (m *MsgExecuteJob) Unmarshal(dAtA []byte) error
func (*MsgExecuteJob) ValidateBasic ¶ added in v0.10.0
func (msg *MsgExecuteJob) ValidateBasic() error
func (*MsgExecuteJob) XXX_DiscardUnknown ¶ added in v0.10.0
func (m *MsgExecuteJob) XXX_DiscardUnknown()
func (*MsgExecuteJob) XXX_Marshal ¶ added in v0.10.0
func (m *MsgExecuteJob) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgExecuteJob) XXX_Merge ¶ added in v0.10.0
func (m *MsgExecuteJob) XXX_Merge(src proto.Message)
func (*MsgExecuteJob) XXX_Size ¶ added in v0.10.0
func (m *MsgExecuteJob) XXX_Size() int
func (*MsgExecuteJob) XXX_Unmarshal ¶ added in v0.10.0
func (m *MsgExecuteJob) XXX_Unmarshal(b []byte) error
type MsgExecuteJobResponse ¶ added in v0.10.0
type MsgExecuteJobResponse struct { // points to the ID of the consensus queue message created from the job // execution MessageID uint64 `protobuf:"varint,1,opt,name=messageID,proto3" json:"messageID,omitempty"` }
func (*MsgExecuteJobResponse) Descriptor ¶ added in v0.10.0
func (*MsgExecuteJobResponse) Descriptor() ([]byte, []int)
func (*MsgExecuteJobResponse) GetMessageID ¶ added in v1.9.1
func (m *MsgExecuteJobResponse) GetMessageID() uint64
func (*MsgExecuteJobResponse) Marshal ¶ added in v0.10.0
func (m *MsgExecuteJobResponse) Marshal() (dAtA []byte, err error)
func (*MsgExecuteJobResponse) MarshalTo ¶ added in v0.10.0
func (m *MsgExecuteJobResponse) MarshalTo(dAtA []byte) (int, error)
func (*MsgExecuteJobResponse) MarshalToSizedBuffer ¶ added in v0.10.0
func (m *MsgExecuteJobResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*MsgExecuteJobResponse) ProtoMessage ¶ added in v0.10.0
func (*MsgExecuteJobResponse) ProtoMessage()
func (*MsgExecuteJobResponse) Reset ¶ added in v0.10.0
func (m *MsgExecuteJobResponse) Reset()
func (*MsgExecuteJobResponse) Size ¶ added in v0.10.0
func (m *MsgExecuteJobResponse) Size() (n int)
func (*MsgExecuteJobResponse) String ¶ added in v0.10.0
func (m *MsgExecuteJobResponse) String() string
func (*MsgExecuteJobResponse) Unmarshal ¶ added in v0.10.0
func (m *MsgExecuteJobResponse) Unmarshal(dAtA []byte) error
func (*MsgExecuteJobResponse) XXX_DiscardUnknown ¶ added in v0.10.0
func (m *MsgExecuteJobResponse) XXX_DiscardUnknown()
func (*MsgExecuteJobResponse) XXX_Marshal ¶ added in v0.10.0
func (m *MsgExecuteJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MsgExecuteJobResponse) XXX_Merge ¶ added in v0.10.0
func (m *MsgExecuteJobResponse) XXX_Merge(src proto.Message)
func (*MsgExecuteJobResponse) XXX_Size ¶ added in v0.10.0
func (m *MsgExecuteJobResponse) XXX_Size() int
func (*MsgExecuteJobResponse) XXX_Unmarshal ¶ added in v0.10.0
func (m *MsgExecuteJobResponse) XXX_Unmarshal(b []byte) error
type MsgServer ¶
type MsgServer interface { CreateJob(context.Context, *MsgCreateJob) (*MsgCreateJobResponse, error) ExecuteJob(context.Context, *MsgExecuteJob) (*MsgExecuteJobResponse, error) }
MsgServer is the server API for Msg service.
type NoData ¶
type NoData struct { }
func (*NoData) Descriptor ¶
func (*NoData) MarshalToSizedBuffer ¶
func (*NoData) ProtoMessage ¶
func (*NoData) ProtoMessage()
func (*NoData) XXX_DiscardUnknown ¶
func (m *NoData) XXX_DiscardUnknown()
func (*NoData) XXX_Marshal ¶
func (*NoData) XXX_Unmarshal ¶
type OnMessageProcessor ¶
type Params ¶
type Params struct { }
Params defines the parameters for the module.
func (*Params) Descriptor ¶
func (*Params) MarshalToSizedBuffer ¶
func (*Params) ParamSetPairs ¶
func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs
ParamSetPairs get the params.ParamSet
func (*Params) ProtoMessage ¶
func (*Params) ProtoMessage()
func (*Params) XXX_DiscardUnknown ¶
func (m *Params) XXX_DiscardUnknown()
func (*Params) XXX_Marshal ¶
func (*Params) XXX_Unmarshal ¶
type Permissions ¶ added in v0.10.0
type Permissions struct { Whitelist []*Runner `protobuf:"bytes,1,rep,name=whitelist,proto3" json:"whitelist,omitempty"` Blacklist []*Runner `protobuf:"bytes,2,rep,name=blacklist,proto3" json:"blacklist,omitempty"` }
func (*Permissions) Descriptor ¶ added in v0.10.0
func (*Permissions) Descriptor() ([]byte, []int)
func (*Permissions) GetBlacklist ¶ added in v0.10.0
func (m *Permissions) GetBlacklist() []*Runner
func (*Permissions) GetWhitelist ¶ added in v0.10.0
func (m *Permissions) GetWhitelist() []*Runner
func (*Permissions) Marshal ¶ added in v0.10.0
func (m *Permissions) Marshal() (dAtA []byte, err error)
func (*Permissions) MarshalTo ¶ added in v0.10.0
func (m *Permissions) MarshalTo(dAtA []byte) (int, error)
func (*Permissions) MarshalToSizedBuffer ¶ added in v0.10.0
func (m *Permissions) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Permissions) ProtoMessage ¶ added in v0.10.0
func (*Permissions) ProtoMessage()
func (*Permissions) Reset ¶ added in v0.10.0
func (m *Permissions) Reset()
func (*Permissions) Size ¶ added in v0.10.0
func (m *Permissions) Size() (n int)
func (*Permissions) String ¶ added in v0.10.0
func (m *Permissions) String() string
func (*Permissions) Unmarshal ¶ added in v0.10.0
func (m *Permissions) Unmarshal(dAtA []byte) error
func (*Permissions) ValidateBasic ¶ added in v0.10.0
func (p *Permissions) ValidateBasic() error
func (*Permissions) XXX_DiscardUnknown ¶ added in v0.10.0
func (m *Permissions) XXX_DiscardUnknown()
func (*Permissions) XXX_Marshal ¶ added in v0.10.0
func (m *Permissions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Permissions) XXX_Merge ¶ added in v0.10.0
func (m *Permissions) XXX_Merge(src proto.Message)
func (*Permissions) XXX_Size ¶ added in v0.10.0
func (m *Permissions) XXX_Size() int
func (*Permissions) XXX_Unmarshal ¶ added in v0.10.0
func (m *Permissions) XXX_Unmarshal(b []byte) error
type QueryClient ¶
type QueryClient interface { // Parameters queries the parameters of the module. Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error) // Queries a list of GetJobByID items. QueryGetJobByID(ctx context.Context, in *QueryGetJobByIDRequest, opts ...grpc.CallOption) (*QueryGetJobByIDResponse, error) }
QueryClient is the client API for Query service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewQueryClient ¶
func NewQueryClient(cc grpc1.ClientConn) QueryClient
type QueryGetJobByIDRequest ¶ added in v0.10.0
type QueryGetJobByIDRequest struct {
JobID string `protobuf:"bytes,1,opt,name=jobID,proto3" json:"jobID,omitempty"`
}
func (*QueryGetJobByIDRequest) Descriptor ¶ added in v0.10.0
func (*QueryGetJobByIDRequest) Descriptor() ([]byte, []int)
func (*QueryGetJobByIDRequest) GetJobID ¶ added in v0.10.0
func (m *QueryGetJobByIDRequest) GetJobID() string
func (*QueryGetJobByIDRequest) Marshal ¶ added in v0.10.0
func (m *QueryGetJobByIDRequest) Marshal() (dAtA []byte, err error)
func (*QueryGetJobByIDRequest) MarshalTo ¶ added in v0.10.0
func (m *QueryGetJobByIDRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetJobByIDRequest) MarshalToSizedBuffer ¶ added in v0.10.0
func (m *QueryGetJobByIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetJobByIDRequest) ProtoMessage ¶ added in v0.10.0
func (*QueryGetJobByIDRequest) ProtoMessage()
func (*QueryGetJobByIDRequest) Reset ¶ added in v0.10.0
func (m *QueryGetJobByIDRequest) Reset()
func (*QueryGetJobByIDRequest) Size ¶ added in v0.10.0
func (m *QueryGetJobByIDRequest) Size() (n int)
func (*QueryGetJobByIDRequest) String ¶ added in v0.10.0
func (m *QueryGetJobByIDRequest) String() string
func (*QueryGetJobByIDRequest) Unmarshal ¶ added in v0.10.0
func (m *QueryGetJobByIDRequest) Unmarshal(dAtA []byte) error
func (*QueryGetJobByIDRequest) XXX_DiscardUnknown ¶ added in v0.10.0
func (m *QueryGetJobByIDRequest) XXX_DiscardUnknown()
func (*QueryGetJobByIDRequest) XXX_Marshal ¶ added in v0.10.0
func (m *QueryGetJobByIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetJobByIDRequest) XXX_Merge ¶ added in v0.10.0
func (m *QueryGetJobByIDRequest) XXX_Merge(src proto.Message)
func (*QueryGetJobByIDRequest) XXX_Size ¶ added in v0.10.0
func (m *QueryGetJobByIDRequest) XXX_Size() int
func (*QueryGetJobByIDRequest) XXX_Unmarshal ¶ added in v0.10.0
func (m *QueryGetJobByIDRequest) XXX_Unmarshal(b []byte) error
type QueryGetJobByIDResponse ¶ added in v0.10.0
type QueryGetJobByIDResponse struct {
Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
}
func (*QueryGetJobByIDResponse) Descriptor ¶ added in v0.10.0
func (*QueryGetJobByIDResponse) Descriptor() ([]byte, []int)
func (*QueryGetJobByIDResponse) GetJob ¶ added in v0.10.0
func (m *QueryGetJobByIDResponse) GetJob() *Job
func (*QueryGetJobByIDResponse) Marshal ¶ added in v0.10.0
func (m *QueryGetJobByIDResponse) Marshal() (dAtA []byte, err error)
func (*QueryGetJobByIDResponse) MarshalTo ¶ added in v0.10.0
func (m *QueryGetJobByIDResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryGetJobByIDResponse) MarshalToSizedBuffer ¶ added in v0.10.0
func (m *QueryGetJobByIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryGetJobByIDResponse) ProtoMessage ¶ added in v0.10.0
func (*QueryGetJobByIDResponse) ProtoMessage()
func (*QueryGetJobByIDResponse) Reset ¶ added in v0.10.0
func (m *QueryGetJobByIDResponse) Reset()
func (*QueryGetJobByIDResponse) Size ¶ added in v0.10.0
func (m *QueryGetJobByIDResponse) Size() (n int)
func (*QueryGetJobByIDResponse) String ¶ added in v0.10.0
func (m *QueryGetJobByIDResponse) String() string
func (*QueryGetJobByIDResponse) Unmarshal ¶ added in v0.10.0
func (m *QueryGetJobByIDResponse) Unmarshal(dAtA []byte) error
func (*QueryGetJobByIDResponse) XXX_DiscardUnknown ¶ added in v0.10.0
func (m *QueryGetJobByIDResponse) XXX_DiscardUnknown()
func (*QueryGetJobByIDResponse) XXX_Marshal ¶ added in v0.10.0
func (m *QueryGetJobByIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryGetJobByIDResponse) XXX_Merge ¶ added in v0.10.0
func (m *QueryGetJobByIDResponse) XXX_Merge(src proto.Message)
func (*QueryGetJobByIDResponse) XXX_Size ¶ added in v0.10.0
func (m *QueryGetJobByIDResponse) XXX_Size() int
func (*QueryGetJobByIDResponse) XXX_Unmarshal ¶ added in v0.10.0
func (m *QueryGetJobByIDResponse) XXX_Unmarshal(b []byte) error
type QueryParamsRequest ¶
type QueryParamsRequest struct { }
QueryParamsRequest is request type for the Query/Params RPC method.
func (*QueryParamsRequest) Descriptor ¶
func (*QueryParamsRequest) Descriptor() ([]byte, []int)
func (*QueryParamsRequest) Marshal ¶
func (m *QueryParamsRequest) Marshal() (dAtA []byte, err error)
func (*QueryParamsRequest) MarshalTo ¶
func (m *QueryParamsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryParamsRequest) MarshalToSizedBuffer ¶
func (m *QueryParamsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryParamsRequest) ProtoMessage ¶
func (*QueryParamsRequest) ProtoMessage()
func (*QueryParamsRequest) Reset ¶
func (m *QueryParamsRequest) Reset()
func (*QueryParamsRequest) Size ¶
func (m *QueryParamsRequest) Size() (n int)
func (*QueryParamsRequest) String ¶
func (m *QueryParamsRequest) String() string
func (*QueryParamsRequest) Unmarshal ¶
func (m *QueryParamsRequest) Unmarshal(dAtA []byte) error
func (*QueryParamsRequest) XXX_DiscardUnknown ¶
func (m *QueryParamsRequest) XXX_DiscardUnknown()
func (*QueryParamsRequest) XXX_Marshal ¶
func (m *QueryParamsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryParamsRequest) XXX_Merge ¶
func (m *QueryParamsRequest) XXX_Merge(src proto.Message)
func (*QueryParamsRequest) XXX_Size ¶
func (m *QueryParamsRequest) XXX_Size() int
func (*QueryParamsRequest) XXX_Unmarshal ¶
func (m *QueryParamsRequest) XXX_Unmarshal(b []byte) error
type QueryParamsResponse ¶
type QueryParamsResponse struct { // params holds all the parameters of this module. Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"` }
QueryParamsResponse is response type for the Query/Params RPC method.
func (*QueryParamsResponse) Descriptor ¶
func (*QueryParamsResponse) Descriptor() ([]byte, []int)
func (*QueryParamsResponse) GetParams ¶
func (m *QueryParamsResponse) GetParams() Params
func (*QueryParamsResponse) Marshal ¶
func (m *QueryParamsResponse) Marshal() (dAtA []byte, err error)
func (*QueryParamsResponse) MarshalTo ¶
func (m *QueryParamsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryParamsResponse) MarshalToSizedBuffer ¶
func (m *QueryParamsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryParamsResponse) ProtoMessage ¶
func (*QueryParamsResponse) ProtoMessage()
func (*QueryParamsResponse) Reset ¶
func (m *QueryParamsResponse) Reset()
func (*QueryParamsResponse) Size ¶
func (m *QueryParamsResponse) Size() (n int)
func (*QueryParamsResponse) String ¶
func (m *QueryParamsResponse) String() string
func (*QueryParamsResponse) Unmarshal ¶
func (m *QueryParamsResponse) Unmarshal(dAtA []byte) error
func (*QueryParamsResponse) XXX_DiscardUnknown ¶
func (m *QueryParamsResponse) XXX_DiscardUnknown()
func (*QueryParamsResponse) XXX_Marshal ¶
func (m *QueryParamsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryParamsResponse) XXX_Merge ¶
func (m *QueryParamsResponse) XXX_Merge(src proto.Message)
func (*QueryParamsResponse) XXX_Size ¶
func (m *QueryParamsResponse) XXX_Size() int
func (*QueryParamsResponse) XXX_Unmarshal ¶
func (m *QueryParamsResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶
type QueryServer interface { // Parameters queries the parameters of the module. Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error) // Queries a list of GetJobByID items. QueryGetJobByID(context.Context, *QueryGetJobByIDRequest) (*QueryGetJobByIDResponse, error) }
QueryServer is the server API for Query service.
type Routing ¶ added in v0.10.0
type Routing struct { // routing information ChainType string `protobuf:"bytes,1,opt,name=chainType,proto3" json:"chainType,omitempty"` ChainReferenceID string `protobuf:"bytes,2,opt,name=chainReferenceID,proto3" json:"chainReferenceID,omitempty"` }
func (*Routing) Descriptor ¶ added in v0.10.0
func (*Routing) GetChainReferenceID ¶ added in v0.10.0
func (*Routing) GetChainType ¶ added in v0.10.0
func (*Routing) MarshalToSizedBuffer ¶ added in v0.10.0
func (*Routing) ProtoMessage ¶ added in v0.10.0
func (*Routing) ProtoMessage()
func (*Routing) XXX_DiscardUnknown ¶ added in v0.10.0
func (m *Routing) XXX_DiscardUnknown()
func (*Routing) XXX_Marshal ¶ added in v0.10.0
func (*Routing) XXX_Unmarshal ¶ added in v0.10.0
type Runner ¶ added in v0.10.0
type Runner struct { ChainType string `protobuf:"bytes,1,opt,name=chainType,proto3" json:"chainType,omitempty"` ChainReferenceID string `protobuf:"bytes,2,opt,name=chainReferenceID,proto3" json:"chainReferenceID,omitempty"` Address []byte `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"` }
Runner defines an actor that runs the job. It can be a smart contract from any other external chain, a direct user on paloma, a smart contract in paloma, etc,...
func (*Runner) Descriptor ¶ added in v0.10.0
func (*Runner) GetAddress ¶ added in v0.10.0
func (*Runner) GetChainReferenceID ¶ added in v0.10.0
func (*Runner) GetChainType ¶ added in v0.10.0
func (*Runner) MarshalToSizedBuffer ¶ added in v0.10.0
func (*Runner) ProtoMessage ¶ added in v0.10.0
func (*Runner) ProtoMessage()
func (*Runner) XXX_DiscardUnknown ¶ added in v0.10.0
func (m *Runner) XXX_DiscardUnknown()
func (*Runner) XXX_Marshal ¶ added in v0.10.0
func (*Runner) XXX_Unmarshal ¶ added in v0.10.0
type ScheduleTrigger ¶ added in v0.10.0
type ScheduleTrigger struct { }
func (*ScheduleTrigger) Descriptor ¶ added in v0.10.0
func (*ScheduleTrigger) Descriptor() ([]byte, []int)
func (*ScheduleTrigger) Marshal ¶ added in v0.10.0
func (m *ScheduleTrigger) Marshal() (dAtA []byte, err error)
func (*ScheduleTrigger) MarshalTo ¶ added in v0.10.0
func (m *ScheduleTrigger) MarshalTo(dAtA []byte) (int, error)
func (*ScheduleTrigger) MarshalToSizedBuffer ¶ added in v0.10.0
func (m *ScheduleTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ScheduleTrigger) ProtoMessage ¶ added in v0.10.0
func (*ScheduleTrigger) ProtoMessage()
func (*ScheduleTrigger) Reset ¶ added in v0.10.0
func (m *ScheduleTrigger) Reset()
func (*ScheduleTrigger) Size ¶ added in v0.10.0
func (m *ScheduleTrigger) Size() (n int)
func (*ScheduleTrigger) String ¶ added in v0.10.0
func (m *ScheduleTrigger) String() string
func (*ScheduleTrigger) Unmarshal ¶ added in v0.10.0
func (m *ScheduleTrigger) Unmarshal(dAtA []byte) error
func (*ScheduleTrigger) XXX_DiscardUnknown ¶ added in v0.10.0
func (m *ScheduleTrigger) XXX_DiscardUnknown()
func (*ScheduleTrigger) XXX_Marshal ¶ added in v0.10.0
func (m *ScheduleTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ScheduleTrigger) XXX_Merge ¶ added in v0.10.0
func (m *ScheduleTrigger) XXX_Merge(src proto.Message)
func (*ScheduleTrigger) XXX_Size ¶ added in v0.10.0
func (m *ScheduleTrigger) XXX_Size() int
func (*ScheduleTrigger) XXX_Unmarshal ¶ added in v0.10.0
func (m *ScheduleTrigger) XXX_Unmarshal(b []byte) error
type SchedulerPacketData ¶
type SchedulerPacketData struct { // Types that are valid to be assigned to Packet: // // *SchedulerPacketData_NoData Packet isSchedulerPacketData_Packet `protobuf_oneof:"packet"` }
func (*SchedulerPacketData) Descriptor ¶
func (*SchedulerPacketData) Descriptor() ([]byte, []int)
func (*SchedulerPacketData) GetNoData ¶
func (m *SchedulerPacketData) GetNoData() *NoData
func (*SchedulerPacketData) GetPacket ¶
func (m *SchedulerPacketData) GetPacket() isSchedulerPacketData_Packet
func (*SchedulerPacketData) Marshal ¶
func (m *SchedulerPacketData) Marshal() (dAtA []byte, err error)
func (*SchedulerPacketData) MarshalTo ¶
func (m *SchedulerPacketData) MarshalTo(dAtA []byte) (int, error)
func (*SchedulerPacketData) MarshalToSizedBuffer ¶
func (m *SchedulerPacketData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SchedulerPacketData) ProtoMessage ¶
func (*SchedulerPacketData) ProtoMessage()
func (*SchedulerPacketData) Reset ¶
func (m *SchedulerPacketData) Reset()
func (*SchedulerPacketData) Size ¶
func (m *SchedulerPacketData) Size() (n int)
func (*SchedulerPacketData) String ¶
func (m *SchedulerPacketData) String() string
func (*SchedulerPacketData) Unmarshal ¶
func (m *SchedulerPacketData) Unmarshal(dAtA []byte) error
func (*SchedulerPacketData) XXX_DiscardUnknown ¶
func (m *SchedulerPacketData) XXX_DiscardUnknown()
func (*SchedulerPacketData) XXX_Marshal ¶
func (m *SchedulerPacketData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SchedulerPacketData) XXX_Merge ¶
func (m *SchedulerPacketData) XXX_Merge(src proto.Message)
func (*SchedulerPacketData) XXX_OneofWrappers ¶
func (*SchedulerPacketData) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*SchedulerPacketData) XXX_Size ¶
func (m *SchedulerPacketData) XXX_Size() int
func (*SchedulerPacketData) XXX_Unmarshal ¶
func (m *SchedulerPacketData) XXX_Unmarshal(b []byte) error
type SchedulerPacketData_NoData ¶
type SchedulerPacketData_NoData struct {
NoData *NoData `protobuf:"bytes,1,opt,name=noData,proto3,oneof" json:"noData,omitempty"`
}
func (*SchedulerPacketData_NoData) MarshalTo ¶
func (m *SchedulerPacketData_NoData) MarshalTo(dAtA []byte) (int, error)
func (*SchedulerPacketData_NoData) MarshalToSizedBuffer ¶
func (m *SchedulerPacketData_NoData) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*SchedulerPacketData_NoData) Size ¶
func (m *SchedulerPacketData_NoData) Size() (n int)
type Trigger ¶ added in v0.10.0
type Trigger struct { // Types that are valid to be assigned to Trigger: // // *Trigger_Schedule // *Trigger_Event Trigger isTrigger_Trigger `protobuf_oneof:"trigger"` }
func (*Trigger) Descriptor ¶ added in v0.10.0
func (*Trigger) GetEvent ¶ added in v0.10.0
func (m *Trigger) GetEvent() *EventTrigger
func (*Trigger) GetSchedule ¶ added in v0.10.0
func (m *Trigger) GetSchedule() *ScheduleTrigger
func (*Trigger) GetTrigger ¶ added in v0.10.0
func (m *Trigger) GetTrigger() isTrigger_Trigger
func (*Trigger) MarshalToSizedBuffer ¶ added in v0.10.0
func (*Trigger) ProtoMessage ¶ added in v0.10.0
func (*Trigger) ProtoMessage()
func (*Trigger) XXX_DiscardUnknown ¶ added in v0.10.0
func (m *Trigger) XXX_DiscardUnknown()
func (*Trigger) XXX_Marshal ¶ added in v0.10.0
func (*Trigger) XXX_OneofWrappers ¶ added in v0.10.0
func (*Trigger) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Trigger) XXX_Unmarshal ¶ added in v0.10.0
type Trigger_Event ¶ added in v0.10.0
type Trigger_Event struct {
Event *EventTrigger `protobuf:"bytes,2,opt,name=event,proto3,oneof" json:"event,omitempty"`
}
func (*Trigger_Event) MarshalTo ¶ added in v0.10.0
func (m *Trigger_Event) MarshalTo(dAtA []byte) (int, error)
func (*Trigger_Event) MarshalToSizedBuffer ¶ added in v0.10.0
func (m *Trigger_Event) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Trigger_Event) Size ¶ added in v0.10.0
func (m *Trigger_Event) Size() (n int)
type Trigger_Schedule ¶ added in v0.10.0
type Trigger_Schedule struct {
Schedule *ScheduleTrigger `protobuf:"bytes,1,opt,name=schedule,proto3,oneof" json:"schedule,omitempty"`
}
func (*Trigger_Schedule) MarshalTo ¶ added in v0.10.0
func (m *Trigger_Schedule) MarshalTo(dAtA []byte) (int, error)
func (*Trigger_Schedule) MarshalToSizedBuffer ¶ added in v0.10.0
func (m *Trigger_Schedule) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Trigger_Schedule) Size ¶ added in v0.10.0
func (m *Trigger_Schedule) Size() (n int)
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer can be embedded to have forward compatible implementations.
func (*UnimplementedMsgServer) CreateJob ¶ added in v0.10.0
func (*UnimplementedMsgServer) CreateJob(ctx context.Context, req *MsgCreateJob) (*MsgCreateJobResponse, error)
func (*UnimplementedMsgServer) ExecuteJob ¶ added in v0.10.0
func (*UnimplementedMsgServer) ExecuteJob(ctx context.Context, req *MsgExecuteJob) (*MsgExecuteJobResponse, error)
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) Params ¶
func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)
func (*UnimplementedQueryServer) QueryGetJobByID ¶ added in v0.10.0
func (*UnimplementedQueryServer) QueryGetJobByID(ctx context.Context, req *QueryGetJobByIDRequest) (*QueryGetJobByIDResponse, error)
type ValsetKeeper ¶ added in v1.4.0
type ValsetKeeper interface {
GetCurrentSnapshot(ctx context.Context) (*valsettypes.Snapshot, error)
}
ValsetKeeper defines the expected interface for interacting with the valset module