types

package
v1.18.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 22, 2024 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// ModuleName defines the module name
	ModuleName = "trigger"

	// 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

	EventOrderLength = 8
	TriggerIDLength  = 8
	QueueIndexLength = 8
	GasLimitLength   = 8
)
View Source 
const (
	BlockHeightPrefix = "block-height"
	BlockTimePrefix   = "block-time"
)

Variables

View Source 
var (
	ErrTriggerNotFound         = cerrs.Register(ModuleName, 2, "trigger not found")
	ErrEventNotFound           = cerrs.Register(ModuleName, 3, "event not found")
	ErrQueueIndexNotFound      = cerrs.Register(ModuleName, 4, "queue index not found")
	ErrQueueEmpty              = cerrs.Register(ModuleName, 5, "queue is empty")
	ErrGasLimitNotFound        = cerrs.Register(ModuleName, 6, "gas limit not found")
	ErrTriggerGasLimitExceeded = cerrs.Register(ModuleName, 7, "gas limit execeeded for trigger")
	ErrInvalidTriggerAuthority = cerrs.Register(ModuleName, 8, "signer does not have authority to destroy trigger")
	ErrNoTriggerEvent          = cerrs.Register(ModuleName, 9, "trigger does not have event")
	ErrInvalidBlockHeight      = cerrs.Register(ModuleName, 10, "block height has already passed")
	ErrInvalidBlockTime        = cerrs.Register(ModuleName, 11, "block time has already passed")
)
View Source 
var (
	ErrInvalidLengthEvent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvent = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	// TriggerKeyPrefix is an initial byte to help group all trigger keys
	TriggerKeyPrefix = []byte{0x01}
	// EventListenerKeyPrefix is an initial byte to help group all event listener keys
	EventListenerKeyPrefix = []byte{0x02}
	// QueueKeyPrefix is an initial byte to help group all queue entry keys
	QueueKeyPrefix = []byte{0x03}
	// GasLimitKeyPrefix is an initial byte to help group all gas limit keys
	GasLimitKeyPrefix = []byte{0x04}
	// NextTriggerIDKey is the key to obtain the next valid trigger id
	NextTriggerIDKey = []byte{0x05}
	// QueueStartIndexKey is the key to obtain the queue's starting index
	QueueStartIndexKey = []byte{0x06}
	// QueueStartIndexKey is the key to obtain the queue's length
	QueueLengthKey = []byte{0x07}
)

KVStore Key Prefixes used for iterator/scans against the store and identification of key types The following keys are used to store Triggers The <trigger_id_bytes> are 8 bytes to uniquely identify a trigger The remaining key is used to track the next valid trigger id

  • 0x01<trigger_id_bytes>: Trigger | 1 | 8 |

  • 0x05: Trigger ID | 1 |

The keys prefixed with 0x02 are used to quickly iterate trigger events during the detection phase The <event_type_bytes> is 32 bytes representing the event type's name. The next 8 bytes <order_bytes> are to help order the events and improve searching The last 8 bytes <trigger_id_bytes> is a the trigger id that the event listener belongs to.

  • 0x02<event_type_bytes><order_bytes><trigger_id_bytes>: []byte{} | 1 | 32 | 8 | 8 |

The key in this section is used to track gas limits for triggers. The <trigger_id_bytes> are 8 bytes that match the trigger that the gas limit belongs to.

  • 0x04<trigger_id_bytes>: uint64 (GasLimit) | 1 | 8 |

These keys are used to represent a queue in the store The <queue_index_bytes> are 8 bytes representing the item's spot in the queue The two additional keys are used as metadata to track and manage the queue.

  • 0x03<queue_index_bytes>: QueuedTrigger | 1 | 8 |

  • 0x06: uint64 (Queue Start Index) | 1 |

  • 0x07: uint64 (Queue Length) | 1 |

View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTrigger        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTrigger          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTrigger = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)

Functions

func GetEventListenerKey 

func GetEventListenerKey(eventName string, order uint64, id TriggerID) []byte

GetEventListenerKey converts an event name, order, and trigger ID into an event registry key format.

func GetEventListenerPrefix 

func GetEventListenerPrefix(eventName string) []byte

GetEventListenerPrefix converts an event name into a prefix for event registry.

func GetEventNameBytes 

func GetEventNameBytes(name string) []byte

GetEventNameBytes returns a set of bytes that uniquely identifies the given event name

func GetGasLimitBytes 

func GetGasLimitBytes(gasLimit uint64) (gasLimitBz []byte)

GetGasLimitBytes returns the byte representation of the gas limit

func GetGasLimitFromBytes 

func GetGasLimitFromBytes(bz []byte) uint64

GetGasLimitFromBytes returns gas limit in uint64 format from a byte array

func GetGasLimitKey 

func GetGasLimitKey(id TriggerID) []byte

GetGasLimitKey converts a gas limit into key format.

func GetNextTriggerIDKey 

func GetNextTriggerIDKey() []byte

GetNextTriggerIDKey gets the key for getting the next trigger ID.

func GetQueueIndexBytes 

func GetQueueIndexBytes(index uint64) (queueIndexBz []byte)

GetQueueIndexBytes returns the byte representation of the queue index

func GetQueueIndexFromBytes 

func GetQueueIndexFromBytes(bz []byte) uint64

GetQueueIndexFromBytes returns the index in uint64 format from a byte array

func GetQueueKey 

func GetQueueKey(index uint64) []byte

GetQueueKey gets the key for storing in the queue.

func GetQueueKeyPrefix 

func GetQueueKeyPrefix() []byte

GetQueueKeyPrefix gets the queue's key prefix

func GetQueueLengthKey 

func GetQueueLengthKey() []byte

GetQueueLengthKey gets the key for storing the queue length

func GetQueueStartIndexKey 

func GetQueueStartIndexKey() []byte

GetQueueStartIndexKey gets the key for storing the start index

func GetTriggerIDBytes 

func GetTriggerIDBytes(triggerID TriggerID) (triggerIDBz []byte)

GetTriggerIDBytes returns the byte representation of the trigger ID

func GetTriggerKey 

func GetTriggerKey(id TriggerID) []byte

GetTriggerKey converts a trigger into key format.

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

ignoring RegisterLegacyAminoCodec registers all the necessary types and interfaces for the double check

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

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 (such as grpc.SendHeader, etc) to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type Attribute 

type Attribute struct {
	// The name of the attribute that the event must have to be considered a match.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The value of the attribute that the event must have to be considered a match.
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

Attribute

func (*Attribute) Descriptor 

func (*Attribute) Descriptor() ([]byte, []int)

func (*Attribute) Equal 

func (this *Attribute) Equal(that interface{}) bool

func (*Attribute) GetName 

func (m *Attribute) GetName() string

func (*Attribute) GetValue 

func (m *Attribute) GetValue() string

func (*Attribute) Marshal 

func (m *Attribute) Marshal() (dAtA []byte, err error)

func (*Attribute) MarshalTo 

func (m *Attribute) MarshalTo(dAtA []byte) (int, error)

func (*Attribute) MarshalToSizedBuffer 

func (m *Attribute) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (Attribute) Matches 

func (a Attribute) Matches(other abci.EventAttribute) bool

Matches checks if two Attributes have the same name and an equal value if one is specified.

func (*Attribute) ProtoMessage 

func (*Attribute) ProtoMessage()

func (*Attribute) Reset 

func (m *Attribute) Reset()

func (*Attribute) Size 

func (m *Attribute) Size() (n int)

func (*Attribute) String 

func (m *Attribute) String() string

func (*Attribute) Unmarshal 

func (m *Attribute) Unmarshal(dAtA []byte) error

func (*Attribute) XXX_DiscardUnknown 

func (m *Attribute) XXX_DiscardUnknown()

func (*Attribute) XXX_Marshal 

func (m *Attribute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Attribute) XXX_Merge 

func (m *Attribute) XXX_Merge(src proto.Message)

func (*Attribute) XXX_Size 

func (m *Attribute) XXX_Size() int

func (*Attribute) XXX_Unmarshal 

func (m *Attribute) XXX_Unmarshal(b []byte) error

type BlockHeightEvent 

type BlockHeightEvent struct {
	// The height that the trigger should fire at.
	BlockHeight uint64 `protobuf:"varint,1,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
}

BlockHeightEvent

func (*BlockHeightEvent) Descriptor 

func (*BlockHeightEvent) Descriptor() ([]byte, []int)

func (*BlockHeightEvent) Equal 

func (this *BlockHeightEvent) Equal(that interface{}) bool

func (*BlockHeightEvent) GetBlockHeight 

func (m *BlockHeightEvent) GetBlockHeight() uint64

func (BlockHeightEvent) GetEventOrder 

func (e BlockHeightEvent) GetEventOrder() uint64

GetEventOrder gets the order for which this event should be processed

func (BlockHeightEvent) GetEventPrefix 

func (e BlockHeightEvent) GetEventPrefix() string

GetEventPrefix gets the prefix for a BlockHeightEvent.

func (*BlockHeightEvent) Marshal 

func (m *BlockHeightEvent) Marshal() (dAtA []byte, err error)

func (*BlockHeightEvent) MarshalTo 

func (m *BlockHeightEvent) MarshalTo(dAtA []byte) (int, error)

func (*BlockHeightEvent) MarshalToSizedBuffer 

func (m *BlockHeightEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlockHeightEvent) ProtoMessage 

func (*BlockHeightEvent) ProtoMessage()

func (*BlockHeightEvent) Reset 

func (m *BlockHeightEvent) Reset()

func (*BlockHeightEvent) Size 

func (m *BlockHeightEvent) Size() (n int)

func (*BlockHeightEvent) String 

func (m *BlockHeightEvent) String() string

func (*BlockHeightEvent) Unmarshal 

func (m *BlockHeightEvent) Unmarshal(dAtA []byte) error

func (BlockHeightEvent) Validate 

func (e BlockHeightEvent) Validate() error

Validate checks if the event data is valid.

func (BlockHeightEvent) ValidateContext 

func (e BlockHeightEvent) ValidateContext(ctx sdk.Context) error

Validate checks if this event is valid with the current context.

func (*BlockHeightEvent) XXX_DiscardUnknown 

func (m *BlockHeightEvent) XXX_DiscardUnknown()

func (*BlockHeightEvent) XXX_Marshal 

func (m *BlockHeightEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockHeightEvent) XXX_Merge 

func (m *BlockHeightEvent) XXX_Merge(src proto.Message)

func (*BlockHeightEvent) XXX_Size 

func (m *BlockHeightEvent) XXX_Size() int

func (*BlockHeightEvent) XXX_Unmarshal 

func (m *BlockHeightEvent) XXX_Unmarshal(b []byte) error

type BlockTimeEvent 

type BlockTimeEvent struct {
	// The time the trigger should fire at.
	Time time.Time `protobuf:"bytes,1,opt,name=time,proto3,stdtime" json:"time"`
}

BlockTimeEvent

func (*BlockTimeEvent) Descriptor 

func (*BlockTimeEvent) Descriptor() ([]byte, []int)

func (*BlockTimeEvent) Equal 

func (this *BlockTimeEvent) Equal(that interface{}) bool

func (BlockTimeEvent) GetEventOrder 

func (e BlockTimeEvent) GetEventOrder() uint64

GetEventOrder gets the order for which this event should be processed

func (BlockTimeEvent) GetEventPrefix 

func (e BlockTimeEvent) GetEventPrefix() string

GetEventPrefix gets the prefix for a BlockTimeEvent.

func (*BlockTimeEvent) GetTime 

func (m *BlockTimeEvent) GetTime() time.Time

func (*BlockTimeEvent) Marshal 

func (m *BlockTimeEvent) Marshal() (dAtA []byte, err error)

func (*BlockTimeEvent) MarshalTo 

func (m *BlockTimeEvent) MarshalTo(dAtA []byte) (int, error)

func (*BlockTimeEvent) MarshalToSizedBuffer 

func (m *BlockTimeEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BlockTimeEvent) ProtoMessage 

func (*BlockTimeEvent) ProtoMessage()

func (*BlockTimeEvent) Reset 

func (m *BlockTimeEvent) Reset()

func (*BlockTimeEvent) Size 

func (m *BlockTimeEvent) Size() (n int)

func (*BlockTimeEvent) String 

func (m *BlockTimeEvent) String() string

func (*BlockTimeEvent) Unmarshal 

func (m *BlockTimeEvent) Unmarshal(dAtA []byte) error

func (BlockTimeEvent) Validate 

func (e BlockTimeEvent) Validate() error

Validate checks if the event data is valid.

func (BlockTimeEvent) ValidateContext 

func (e BlockTimeEvent) ValidateContext(ctx sdk.Context) error

Validate checks if this event is valid with the current context.

func (*BlockTimeEvent) XXX_DiscardUnknown 

func (m *BlockTimeEvent) XXX_DiscardUnknown()

func (*BlockTimeEvent) XXX_Marshal 

func (m *BlockTimeEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockTimeEvent) XXX_Merge 

func (m *BlockTimeEvent) XXX_Merge(src proto.Message)

func (*BlockTimeEvent) XXX_Size 

func (m *BlockTimeEvent) XXX_Size() int

func (*BlockTimeEvent) XXX_Unmarshal 

func (m *BlockTimeEvent) XXX_Unmarshal(b []byte) error

type EventTriggerCreated 

type EventTriggerCreated struct {
	// trigger_id is a unique identifier of the trigger.
	TriggerId string `protobuf:"bytes,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
}

EventTriggerCreated is an event for when a trigger is created

func (*EventTriggerCreated) Descriptor 

func (*EventTriggerCreated) Descriptor() ([]byte, []int)

func (*EventTriggerCreated) GetTriggerId 

func (m *EventTriggerCreated) GetTriggerId() string

func (*EventTriggerCreated) Marshal 

func (m *EventTriggerCreated) Marshal() (dAtA []byte, err error)

func (*EventTriggerCreated) MarshalTo 

func (m *EventTriggerCreated) MarshalTo(dAtA []byte) (int, error)

func (*EventTriggerCreated) MarshalToSizedBuffer 

func (m *EventTriggerCreated) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventTriggerCreated) ProtoMessage 

func (*EventTriggerCreated) ProtoMessage()

func (*EventTriggerCreated) Reset 

func (m *EventTriggerCreated) Reset()

func (*EventTriggerCreated) Size 

func (m *EventTriggerCreated) Size() (n int)

func (*EventTriggerCreated) String 

func (m *EventTriggerCreated) String() string

func (*EventTriggerCreated) Unmarshal 

func (m *EventTriggerCreated) Unmarshal(dAtA []byte) error

func (*EventTriggerCreated) XXX_DiscardUnknown 

func (m *EventTriggerCreated) XXX_DiscardUnknown()

func (*EventTriggerCreated) XXX_Marshal 

func (m *EventTriggerCreated) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventTriggerCreated) XXX_Merge 

func (m *EventTriggerCreated) XXX_Merge(src proto.Message)

func (*EventTriggerCreated) XXX_Size 

func (m *EventTriggerCreated) XXX_Size() int

func (*EventTriggerCreated) XXX_Unmarshal 

func (m *EventTriggerCreated) XXX_Unmarshal(b []byte) error

type EventTriggerDestroyed 

type EventTriggerDestroyed struct {
	// trigger_id is a unique identifier of the trigger.
	TriggerId string `protobuf:"bytes,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
}

EventTriggerDestroyed is an event for when a trigger is destroyed

func (*EventTriggerDestroyed) Descriptor 

func (*EventTriggerDestroyed) Descriptor() ([]byte, []int)

func (*EventTriggerDestroyed) GetTriggerId 

func (m *EventTriggerDestroyed) GetTriggerId() string

func (*EventTriggerDestroyed) Marshal 

func (m *EventTriggerDestroyed) Marshal() (dAtA []byte, err error)

func (*EventTriggerDestroyed) MarshalTo 

func (m *EventTriggerDestroyed) MarshalTo(dAtA []byte) (int, error)

func (*EventTriggerDestroyed) MarshalToSizedBuffer 

func (m *EventTriggerDestroyed) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventTriggerDestroyed) ProtoMessage 

func (*EventTriggerDestroyed) ProtoMessage()

func (*EventTriggerDestroyed) Reset 

func (m *EventTriggerDestroyed) Reset()

func (*EventTriggerDestroyed) Size 

func (m *EventTriggerDestroyed) Size() (n int)

func (*EventTriggerDestroyed) String 

func (m *EventTriggerDestroyed) String() string

func (*EventTriggerDestroyed) Unmarshal 

func (m *EventTriggerDestroyed) Unmarshal(dAtA []byte) error

func (*EventTriggerDestroyed) XXX_DiscardUnknown 

func (m *EventTriggerDestroyed) XXX_DiscardUnknown()

func (*EventTriggerDestroyed) XXX_Marshal 

func (m *EventTriggerDestroyed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventTriggerDestroyed) XXX_Merge 

func (m *EventTriggerDestroyed) XXX_Merge(src proto.Message)

func (*EventTriggerDestroyed) XXX_Size 

func (m *EventTriggerDestroyed) XXX_Size() int

func (*EventTriggerDestroyed) XXX_Unmarshal 

func (m *EventTriggerDestroyed) XXX_Unmarshal(b []byte) error

type EventTriggerDetected added in v1.17.0 

type EventTriggerDetected struct {
	// trigger_id is a unique identifier of the trigger.
	TriggerId string `protobuf:"bytes,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
}

EventTriggerDetected is an event for when a trigger's event is detected

func (*EventTriggerDetected) Descriptor added in v1.17.0 

func (*EventTriggerDetected) Descriptor() ([]byte, []int)

func (*EventTriggerDetected) GetTriggerId added in v1.17.0 

func (m *EventTriggerDetected) GetTriggerId() string

func (*EventTriggerDetected) Marshal added in v1.17.0 

func (m *EventTriggerDetected) Marshal() (dAtA []byte, err error)

func (*EventTriggerDetected) MarshalTo added in v1.17.0 

func (m *EventTriggerDetected) MarshalTo(dAtA []byte) (int, error)

func (*EventTriggerDetected) MarshalToSizedBuffer added in v1.17.0 

func (m *EventTriggerDetected) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventTriggerDetected) ProtoMessage added in v1.17.0 

func (*EventTriggerDetected) ProtoMessage()

func (*EventTriggerDetected) Reset added in v1.17.0 

func (m *EventTriggerDetected) Reset()

func (*EventTriggerDetected) Size added in v1.17.0 

func (m *EventTriggerDetected) Size() (n int)

func (*EventTriggerDetected) String added in v1.17.0 

func (m *EventTriggerDetected) String() string

func (*EventTriggerDetected) Unmarshal added in v1.17.0 

func (m *EventTriggerDetected) Unmarshal(dAtA []byte) error

func (*EventTriggerDetected) XXX_DiscardUnknown added in v1.17.0 

func (m *EventTriggerDetected) XXX_DiscardUnknown()

func (*EventTriggerDetected) XXX_Marshal added in v1.17.0 

func (m *EventTriggerDetected) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventTriggerDetected) XXX_Merge added in v1.17.0 

func (m *EventTriggerDetected) XXX_Merge(src proto.Message)

func (*EventTriggerDetected) XXX_Size added in v1.17.0 

func (m *EventTriggerDetected) XXX_Size() int

func (*EventTriggerDetected) XXX_Unmarshal added in v1.17.0 

func (m *EventTriggerDetected) XXX_Unmarshal(b []byte) error

type EventTriggerExecuted added in v1.17.0 

type EventTriggerExecuted struct {
	// trigger_id is a unique identifier of the trigger.
	TriggerId string `protobuf:"bytes,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// owner is the creator of the trigger.
	Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	// success indicates if all executed actions were successful.
	Success bool `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"`
}

EventTriggerExecuted is an event for when a trigger is executed.

func (*EventTriggerExecuted) Descriptor added in v1.17.0 

func (*EventTriggerExecuted) Descriptor() ([]byte, []int)

func (*EventTriggerExecuted) GetOwner added in v1.17.0 

func (m *EventTriggerExecuted) GetOwner() string

func (*EventTriggerExecuted) GetSuccess added in v1.17.0 

func (m *EventTriggerExecuted) GetSuccess() bool

func (*EventTriggerExecuted) GetTriggerId added in v1.17.0 

func (m *EventTriggerExecuted) GetTriggerId() string

func (*EventTriggerExecuted) Marshal added in v1.17.0 

func (m *EventTriggerExecuted) Marshal() (dAtA []byte, err error)

func (*EventTriggerExecuted) MarshalTo added in v1.17.0 

func (m *EventTriggerExecuted) MarshalTo(dAtA []byte) (int, error)

func (*EventTriggerExecuted) MarshalToSizedBuffer added in v1.17.0 

func (m *EventTriggerExecuted) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventTriggerExecuted) ProtoMessage added in v1.17.0 

func (*EventTriggerExecuted) ProtoMessage()

func (*EventTriggerExecuted) Reset added in v1.17.0 

func (m *EventTriggerExecuted) Reset()

func (*EventTriggerExecuted) Size added in v1.17.0 

func (m *EventTriggerExecuted) Size() (n int)

func (*EventTriggerExecuted) String added in v1.17.0 

func (m *EventTriggerExecuted) String() string

func (*EventTriggerExecuted) Unmarshal added in v1.17.0 

func (m *EventTriggerExecuted) Unmarshal(dAtA []byte) error

func (*EventTriggerExecuted) XXX_DiscardUnknown added in v1.17.0 

func (m *EventTriggerExecuted) XXX_DiscardUnknown()

func (*EventTriggerExecuted) XXX_Marshal added in v1.17.0 

func (m *EventTriggerExecuted) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EventTriggerExecuted) XXX_Merge added in v1.17.0 

func (m *EventTriggerExecuted) XXX_Merge(src proto.Message)

func (*EventTriggerExecuted) XXX_Size added in v1.17.0 

func (m *EventTriggerExecuted) XXX_Size() int

func (*EventTriggerExecuted) XXX_Unmarshal added in v1.17.0 

func (m *EventTriggerExecuted) XXX_Unmarshal(b []byte) error

type GasLimit 

type GasLimit struct {
	// The identifier of the trigger this GasLimit belongs to.
	TriggerId uint64 `protobuf:"varint,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// The maximum amount of gas that the trigger can use.
	Amount uint64 `protobuf:"varint,2,opt,name=amount,proto3" json:"amount,omitempty"`
}

GasLimit defines the trigger module's grouping of a trigger and a gas limit

func (*GasLimit) Descriptor 

func (*GasLimit) Descriptor() ([]byte, []int)

func (*GasLimit) GetAmount 

func (m *GasLimit) GetAmount() uint64

func (*GasLimit) GetTriggerId 

func (m *GasLimit) GetTriggerId() uint64

func (*GasLimit) Marshal 

func (m *GasLimit) Marshal() (dAtA []byte, err error)

func (*GasLimit) MarshalTo 

func (m *GasLimit) MarshalTo(dAtA []byte) (int, error)

func (*GasLimit) MarshalToSizedBuffer 

func (m *GasLimit) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GasLimit) ProtoMessage 

func (*GasLimit) ProtoMessage()

func (*GasLimit) Reset 

func (m *GasLimit) Reset()

func (*GasLimit) Size 

func (m *GasLimit) Size() (n int)

func (*GasLimit) String 

func (m *GasLimit) String() string

func (*GasLimit) Unmarshal 

func (m *GasLimit) Unmarshal(dAtA []byte) error

func (*GasLimit) XXX_DiscardUnknown 

func (m *GasLimit) XXX_DiscardUnknown()

func (*GasLimit) XXX_Marshal 

func (m *GasLimit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GasLimit) XXX_Merge 

func (m *GasLimit) XXX_Merge(src proto.Message)

func (*GasLimit) XXX_Size 

func (m *GasLimit) XXX_Size() int

func (*GasLimit) XXX_Unmarshal 

func (m *GasLimit) XXX_Unmarshal(b []byte) error

type GenesisState 

type GenesisState struct {
	// Trigger id is the next auto incremented id to be assigned to the next created trigger
	TriggerId uint64 `protobuf:"varint,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	// Queue start is the starting index of the queue.
	QueueStart uint64 `protobuf:"varint,2,opt,name=queue_start,json=queueStart,proto3" json:"queue_start,omitempty"`
	// Triggers to initially start with.
	Triggers []Trigger `protobuf:"bytes,3,rep,name=triggers,proto3" json:"triggers"`
	// Maximum amount of gas that the triggers can use.
	GasLimits []GasLimit `protobuf:"bytes,4,rep,name=gas_limits,json=gasLimits,proto3" json:"gas_limits"`
	// Triggers to initially start with in the queue.
	QueuedTriggers []QueuedTrigger `protobuf:"bytes,5,rep,name=queued_triggers,json=queuedTriggers,proto3" json:"queued_triggers"`
}

GenesisState defines the trigger module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default trigger genesis state

func NewGenesisState 

func NewGenesisState(triggerID, queueStart uint64, triggers []Trigger, gasLimits []GasLimit, queuedTriggers []QueuedTrigger) *GenesisState

func (*GenesisState) Descriptor 

func (*GenesisState) Descriptor() ([]byte, []int)

func (*GenesisState) Marshal 

func (m *GenesisState) Marshal() (dAtA []byte, err error)

func (*GenesisState) MarshalTo 

func (m *GenesisState) MarshalTo(dAtA []byte) (int, 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) UnpackInterfaces 

func (gs GenesisState) UnpackInterfaces(unpacker types.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

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 MsgClient 

type MsgClient interface {
	// CreateTrigger is the RPC endpoint for creating a trigger
	CreateTrigger(ctx context.Context, in *MsgCreateTriggerRequest, opts ...grpc.CallOption) (*MsgCreateTriggerResponse, error)
	// DestroyTrigger is the RPC endpoint for creating a trigger
	DestroyTrigger(ctx context.Context, in *MsgDestroyTriggerRequest, opts ...grpc.CallOption) (*MsgDestroyTriggerResponse, 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 MsgCreateTriggerRequest 

type MsgCreateTriggerRequest struct {
	// The signing authorities for the request
	Authorities []string `protobuf:"bytes,1,rep,name=authorities,proto3" json:"authorities,omitempty"`
	// The event that must be detected for the trigger to fire.
	Event *types.Any `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// The messages to run when the trigger fires.
	Actions []*types.Any `protobuf:"bytes,3,rep,name=actions,proto3" json:"actions,omitempty"`
}

MsgCreateTriggerRequest is the request type for creating a trigger RPC

func MustNewCreateTriggerRequest 

func MustNewCreateTriggerRequest(authorities []string, event TriggerEventI, msgs []sdk.Msg) *MsgCreateTriggerRequest

func NewCreateTriggerRequest 

func NewCreateTriggerRequest(authorities []string, event TriggerEventI, msgs []sdk.Msg) (*MsgCreateTriggerRequest, error)

NewCreateTriggerRequest Creates a new trigger create request

func (*MsgCreateTriggerRequest) Descriptor 

func (*MsgCreateTriggerRequest) Descriptor() ([]byte, []int)

func (*MsgCreateTriggerRequest) Equal 

func (this *MsgCreateTriggerRequest) Equal(that interface{}) bool

func (*MsgCreateTriggerRequest) GetActions 

func (m *MsgCreateTriggerRequest) GetActions() []*types.Any

func (*MsgCreateTriggerRequest) GetAuthorities 

func (m *MsgCreateTriggerRequest) GetAuthorities() []string

func (*MsgCreateTriggerRequest) GetEvent 

func (m *MsgCreateTriggerRequest) GetEvent() *types.Any

func (MsgCreateTriggerRequest) GetSigners 

func (msg MsgCreateTriggerRequest) GetSigners() []sdk.AccAddress

GetSigners indicates that the message must have been signed by the parent.

func (MsgCreateTriggerRequest) GetTriggerEventI 

func (msg MsgCreateTriggerRequest) GetTriggerEventI() (TriggerEventI, error)

GetTriggerEventI returns unpacked TriggerEvent

func (*MsgCreateTriggerRequest) Marshal 

func (m *MsgCreateTriggerRequest) Marshal() (dAtA []byte, err error)

func (*MsgCreateTriggerRequest) MarshalTo 

func (m *MsgCreateTriggerRequest) MarshalTo(dAtA []byte) (int, error)

func (*MsgCreateTriggerRequest) MarshalToSizedBuffer 

func (m *MsgCreateTriggerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCreateTriggerRequest) ProtoMessage 

func (*MsgCreateTriggerRequest) ProtoMessage()

func (*MsgCreateTriggerRequest) Reset 

func (m *MsgCreateTriggerRequest) Reset()

func (*MsgCreateTriggerRequest) Size 

func (m *MsgCreateTriggerRequest) Size() (n int)

func (*MsgCreateTriggerRequest) String 

func (m *MsgCreateTriggerRequest) String() string

func (*MsgCreateTriggerRequest) Unmarshal 

func (m *MsgCreateTriggerRequest) Unmarshal(dAtA []byte) error

func (MsgCreateTriggerRequest) UnpackInterfaces 

func (msg MsgCreateTriggerRequest) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (MsgCreateTriggerRequest) ValidateBasic 

func (msg MsgCreateTriggerRequest) ValidateBasic() error

ValidateBasic runs stateless validation checks on the message.

func (*MsgCreateTriggerRequest) XXX_DiscardUnknown 

func (m *MsgCreateTriggerRequest) XXX_DiscardUnknown()

func (*MsgCreateTriggerRequest) XXX_Marshal 

func (m *MsgCreateTriggerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCreateTriggerRequest) XXX_Merge 

func (m *MsgCreateTriggerRequest) XXX_Merge(src proto.Message)

func (*MsgCreateTriggerRequest) XXX_Size 

func (m *MsgCreateTriggerRequest) XXX_Size() int

func (*MsgCreateTriggerRequest) XXX_Unmarshal 

func (m *MsgCreateTriggerRequest) XXX_Unmarshal(b []byte) error

type MsgCreateTriggerResponse 

type MsgCreateTriggerResponse struct {
	// trigger id that is generated on creation.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

MsgCreateTriggerResponse is the response type for creating a trigger RPC

func (*MsgCreateTriggerResponse) Descriptor 

func (*MsgCreateTriggerResponse) Descriptor() ([]byte, []int)

func (*MsgCreateTriggerResponse) GetId 

func (m *MsgCreateTriggerResponse) GetId() uint64

func (*MsgCreateTriggerResponse) Marshal 

func (m *MsgCreateTriggerResponse) Marshal() (dAtA []byte, err error)

func (*MsgCreateTriggerResponse) MarshalTo 

func (m *MsgCreateTriggerResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgCreateTriggerResponse) MarshalToSizedBuffer 

func (m *MsgCreateTriggerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgCreateTriggerResponse) ProtoMessage 

func (*MsgCreateTriggerResponse) ProtoMessage()

func (*MsgCreateTriggerResponse) Reset 

func (m *MsgCreateTriggerResponse) Reset()

func (*MsgCreateTriggerResponse) Size 

func (m *MsgCreateTriggerResponse) Size() (n int)

func (*MsgCreateTriggerResponse) String 

func (m *MsgCreateTriggerResponse) String() string

func (*MsgCreateTriggerResponse) Unmarshal 

func (m *MsgCreateTriggerResponse) Unmarshal(dAtA []byte) error

func (*MsgCreateTriggerResponse) XXX_DiscardUnknown 

func (m *MsgCreateTriggerResponse) XXX_DiscardUnknown()

func (*MsgCreateTriggerResponse) XXX_Marshal 

func (m *MsgCreateTriggerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgCreateTriggerResponse) XXX_Merge 

func (m *MsgCreateTriggerResponse) XXX_Merge(src proto.Message)

func (*MsgCreateTriggerResponse) XXX_Size 

func (m *MsgCreateTriggerResponse) XXX_Size() int

func (*MsgCreateTriggerResponse) XXX_Unmarshal 

func (m *MsgCreateTriggerResponse) XXX_Unmarshal(b []byte) error

type MsgDestroyTriggerRequest 

type MsgDestroyTriggerRequest struct {
	// the id of the trigger to destroy.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The signing authority for the request
	Authority string `protobuf:"bytes,2,opt,name=authority,proto3" json:"authority,omitempty"`
}

MsgDestroyTriggerRequest is the request type for creating a trigger RPC

func NewDestroyTriggerRequest 

func NewDestroyTriggerRequest(authority string, id TriggerID) *MsgDestroyTriggerRequest

NewDestroyTriggerRequest Creates a new trigger destroy request

func (*MsgDestroyTriggerRequest) Descriptor 

func (*MsgDestroyTriggerRequest) Descriptor() ([]byte, []int)

func (*MsgDestroyTriggerRequest) Equal 

func (this *MsgDestroyTriggerRequest) Equal(that interface{}) bool

func (*MsgDestroyTriggerRequest) GetAuthority 

func (m *MsgDestroyTriggerRequest) GetAuthority() string

func (*MsgDestroyTriggerRequest) GetId 

func (m *MsgDestroyTriggerRequest) GetId() uint64

func (MsgDestroyTriggerRequest) GetSigners 

func (msg MsgDestroyTriggerRequest) GetSigners() []sdk.AccAddress

GetSigners indicates that the message must have been signed by the parent.

func (*MsgDestroyTriggerRequest) Marshal 

func (m *MsgDestroyTriggerRequest) Marshal() (dAtA []byte, err error)

func (*MsgDestroyTriggerRequest) MarshalTo 

func (m *MsgDestroyTriggerRequest) MarshalTo(dAtA []byte) (int, error)

func (*MsgDestroyTriggerRequest) MarshalToSizedBuffer 

func (m *MsgDestroyTriggerRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgDestroyTriggerRequest) ProtoMessage 

func (*MsgDestroyTriggerRequest) ProtoMessage()

func (*MsgDestroyTriggerRequest) Reset 

func (m *MsgDestroyTriggerRequest) Reset()

func (*MsgDestroyTriggerRequest) Size 

func (m *MsgDestroyTriggerRequest) Size() (n int)

func (*MsgDestroyTriggerRequest) String 

func (m *MsgDestroyTriggerRequest) String() string

func (*MsgDestroyTriggerRequest) Unmarshal 

func (m *MsgDestroyTriggerRequest) Unmarshal(dAtA []byte) error

func (MsgDestroyTriggerRequest) ValidateBasic 

func (msg MsgDestroyTriggerRequest) ValidateBasic() error

ValidateBasic runs stateless validation checks on the message.

func (*MsgDestroyTriggerRequest) XXX_DiscardUnknown 

func (m *MsgDestroyTriggerRequest) XXX_DiscardUnknown()

func (*MsgDestroyTriggerRequest) XXX_Marshal 

func (m *MsgDestroyTriggerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgDestroyTriggerRequest) XXX_Merge 

func (m *MsgDestroyTriggerRequest) XXX_Merge(src proto.Message)

func (*MsgDestroyTriggerRequest) XXX_Size 

func (m *MsgDestroyTriggerRequest) XXX_Size() int

func (*MsgDestroyTriggerRequest) XXX_Unmarshal 

func (m *MsgDestroyTriggerRequest) XXX_Unmarshal(b []byte) error

type MsgDestroyTriggerResponse 

type MsgDestroyTriggerResponse struct {
}

MsgDestroyTriggerResponse is the response type for creating a trigger RPC

func (*MsgDestroyTriggerResponse) Descriptor 

func (*MsgDestroyTriggerResponse) Descriptor() ([]byte, []int)

func (*MsgDestroyTriggerResponse) Marshal 

func (m *MsgDestroyTriggerResponse) Marshal() (dAtA []byte, err error)

func (*MsgDestroyTriggerResponse) MarshalTo 

func (m *MsgDestroyTriggerResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgDestroyTriggerResponse) MarshalToSizedBuffer 

func (m *MsgDestroyTriggerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgDestroyTriggerResponse) ProtoMessage 

func (*MsgDestroyTriggerResponse) ProtoMessage()

func (*MsgDestroyTriggerResponse) Reset 

func (m *MsgDestroyTriggerResponse) Reset()

func (*MsgDestroyTriggerResponse) Size 

func (m *MsgDestroyTriggerResponse) Size() (n int)

func (*MsgDestroyTriggerResponse) String 

func (m *MsgDestroyTriggerResponse) String() string

func (*MsgDestroyTriggerResponse) Unmarshal 

func (m *MsgDestroyTriggerResponse) Unmarshal(dAtA []byte) error

func (*MsgDestroyTriggerResponse) XXX_DiscardUnknown 

func (m *MsgDestroyTriggerResponse) XXX_DiscardUnknown()

func (*MsgDestroyTriggerResponse) XXX_Marshal 

func (m *MsgDestroyTriggerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgDestroyTriggerResponse) XXX_Merge 

func (m *MsgDestroyTriggerResponse) XXX_Merge(src proto.Message)

func (*MsgDestroyTriggerResponse) XXX_Size 

func (m *MsgDestroyTriggerResponse) XXX_Size() int

func (*MsgDestroyTriggerResponse) XXX_Unmarshal 

func (m *MsgDestroyTriggerResponse) XXX_Unmarshal(b []byte) error

type MsgServer 

type MsgServer interface {
	// CreateTrigger is the RPC endpoint for creating a trigger
	CreateTrigger(context.Context, *MsgCreateTriggerRequest) (*MsgCreateTriggerResponse, error)
	// DestroyTrigger is the RPC endpoint for creating a trigger
	DestroyTrigger(context.Context, *MsgDestroyTriggerRequest) (*MsgDestroyTriggerResponse, error)
}

MsgServer is the server API for Msg service.

type QueryClient 

type QueryClient interface {
	// TriggerByID returns a trigger matching the ID.
	TriggerByID(ctx context.Context, in *QueryTriggerByIDRequest, opts ...grpc.CallOption) (*QueryTriggerByIDResponse, error)
	// Triggers returns the list of triggers.
	Triggers(ctx context.Context, in *QueryTriggersRequest, opts ...grpc.CallOption) (*QueryTriggersResponse, 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 QueryServer 

type QueryServer interface {
	// TriggerByID returns a trigger matching the ID.
	TriggerByID(context.Context, *QueryTriggerByIDRequest) (*QueryTriggerByIDResponse, error)
	// Triggers returns the list of triggers.
	Triggers(context.Context, *QueryTriggersRequest) (*QueryTriggersResponse, error)
}

QueryServer is the server API for Query service.

type QueryTriggerByIDRequest 

type QueryTriggerByIDRequest struct {
	// The id of the trigger to query.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

QueryTriggerByIDRequest queries for the Trigger with an identifier of id.

func (*QueryTriggerByIDRequest) Descriptor 

func (*QueryTriggerByIDRequest) Descriptor() ([]byte, []int)

func (*QueryTriggerByIDRequest) GetId 

func (m *QueryTriggerByIDRequest) GetId() uint64

func (*QueryTriggerByIDRequest) Marshal 

func (m *QueryTriggerByIDRequest) Marshal() (dAtA []byte, err error)

func (*QueryTriggerByIDRequest) MarshalTo 

func (m *QueryTriggerByIDRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryTriggerByIDRequest) MarshalToSizedBuffer 

func (m *QueryTriggerByIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryTriggerByIDRequest) ProtoMessage 

func (*QueryTriggerByIDRequest) ProtoMessage()

func (*QueryTriggerByIDRequest) Reset 

func (m *QueryTriggerByIDRequest) Reset()

func (*QueryTriggerByIDRequest) Size 

func (m *QueryTriggerByIDRequest) Size() (n int)

func (*QueryTriggerByIDRequest) String 

func (m *QueryTriggerByIDRequest) String() string

func (*QueryTriggerByIDRequest) Unmarshal 

func (m *QueryTriggerByIDRequest) Unmarshal(dAtA []byte) error

func (*QueryTriggerByIDRequest) XXX_DiscardUnknown 

func (m *QueryTriggerByIDRequest) XXX_DiscardUnknown()

func (*QueryTriggerByIDRequest) XXX_Marshal 

func (m *QueryTriggerByIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryTriggerByIDRequest) XXX_Merge 

func (m *QueryTriggerByIDRequest) XXX_Merge(src proto.Message)

func (*QueryTriggerByIDRequest) XXX_Size 

func (m *QueryTriggerByIDRequest) XXX_Size() int

func (*QueryTriggerByIDRequest) XXX_Unmarshal 

func (m *QueryTriggerByIDRequest) XXX_Unmarshal(b []byte) error

type QueryTriggerByIDResponse 

type QueryTriggerByIDResponse struct {
	// The trigger object that was queried for.
	Trigger *Trigger `protobuf:"bytes,1,opt,name=trigger,proto3" json:"trigger,omitempty"`
}

QueryTriggerByIDResponse contains the requested Trigger.

func (*QueryTriggerByIDResponse) Descriptor 

func (*QueryTriggerByIDResponse) Descriptor() ([]byte, []int)

func (*QueryTriggerByIDResponse) GetTrigger 

func (m *QueryTriggerByIDResponse) GetTrigger() *Trigger

func (*QueryTriggerByIDResponse) Marshal 

func (m *QueryTriggerByIDResponse) Marshal() (dAtA []byte, err error)

func (*QueryTriggerByIDResponse) MarshalTo 

func (m *QueryTriggerByIDResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryTriggerByIDResponse) MarshalToSizedBuffer 

func (m *QueryTriggerByIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryTriggerByIDResponse) ProtoMessage 

func (*QueryTriggerByIDResponse) ProtoMessage()

func (*QueryTriggerByIDResponse) Reset 

func (m *QueryTriggerByIDResponse) Reset()

func (*QueryTriggerByIDResponse) Size 

func (m *QueryTriggerByIDResponse) Size() (n int)

func (*QueryTriggerByIDResponse) String 

func (m *QueryTriggerByIDResponse) String() string

func (*QueryTriggerByIDResponse) Unmarshal 

func (m *QueryTriggerByIDResponse) Unmarshal(dAtA []byte) error

func (*QueryTriggerByIDResponse) XXX_DiscardUnknown 

func (m *QueryTriggerByIDResponse) XXX_DiscardUnknown()

func (*QueryTriggerByIDResponse) XXX_Marshal 

func (m *QueryTriggerByIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryTriggerByIDResponse) XXX_Merge 

func (m *QueryTriggerByIDResponse) XXX_Merge(src proto.Message)

func (*QueryTriggerByIDResponse) XXX_Size 

func (m *QueryTriggerByIDResponse) XXX_Size() int

func (*QueryTriggerByIDResponse) XXX_Unmarshal 

func (m *QueryTriggerByIDResponse) XXX_Unmarshal(b []byte) error

type QueryTriggersRequest 

type QueryTriggersRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,99,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryTriggersRequest queries for all triggers.

func (*QueryTriggersRequest) Descriptor 

func (*QueryTriggersRequest) Descriptor() ([]byte, []int)

func (*QueryTriggersRequest) GetPagination 

func (m *QueryTriggersRequest) GetPagination() *query.PageRequest

func (*QueryTriggersRequest) Marshal 

func (m *QueryTriggersRequest) Marshal() (dAtA []byte, err error)

func (*QueryTriggersRequest) MarshalTo 

func (m *QueryTriggersRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryTriggersRequest) MarshalToSizedBuffer 

func (m *QueryTriggersRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryTriggersRequest) ProtoMessage 

func (*QueryTriggersRequest) ProtoMessage()

func (*QueryTriggersRequest) Reset 

func (m *QueryTriggersRequest) Reset()

func (*QueryTriggersRequest) Size 

func (m *QueryTriggersRequest) Size() (n int)

func (*QueryTriggersRequest) String 

func (m *QueryTriggersRequest) String() string

func (*QueryTriggersRequest) Unmarshal 

func (m *QueryTriggersRequest) Unmarshal(dAtA []byte) error

func (*QueryTriggersRequest) XXX_DiscardUnknown 

func (m *QueryTriggersRequest) XXX_DiscardUnknown()

func (*QueryTriggersRequest) XXX_Marshal 

func (m *QueryTriggersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryTriggersRequest) XXX_Merge 

func (m *QueryTriggersRequest) XXX_Merge(src proto.Message)

func (*QueryTriggersRequest) XXX_Size 

func (m *QueryTriggersRequest) XXX_Size() int

func (*QueryTriggersRequest) XXX_Unmarshal 

func (m *QueryTriggersRequest) XXX_Unmarshal(b []byte) error

type QueryTriggersResponse 

type QueryTriggersResponse struct {
	// List of Trigger objects.
	Triggers []Trigger `protobuf:"bytes,1,rep,name=triggers,proto3" json:"triggers"`
	// pagination defines an optional pagination for the response.
	Pagination *query.PageResponse `protobuf:"bytes,99,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryTriggersResponse contains the list of Triggers.

func (*QueryTriggersResponse) Descriptor 

func (*QueryTriggersResponse) Descriptor() ([]byte, []int)

func (*QueryTriggersResponse) GetPagination 

func (m *QueryTriggersResponse) GetPagination() *query.PageResponse

func (*QueryTriggersResponse) GetTriggers 

func (m *QueryTriggersResponse) GetTriggers() []Trigger

func (*QueryTriggersResponse) Marshal 

func (m *QueryTriggersResponse) Marshal() (dAtA []byte, err error)

func (*QueryTriggersResponse) MarshalTo 

func (m *QueryTriggersResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryTriggersResponse) MarshalToSizedBuffer 

func (m *QueryTriggersResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryTriggersResponse) ProtoMessage 

func (*QueryTriggersResponse) ProtoMessage()

func (*QueryTriggersResponse) Reset 

func (m *QueryTriggersResponse) Reset()

func (*QueryTriggersResponse) Size 

func (m *QueryTriggersResponse) Size() (n int)

func (*QueryTriggersResponse) String 

func (m *QueryTriggersResponse) String() string

func (*QueryTriggersResponse) Unmarshal 

func (m *QueryTriggersResponse) Unmarshal(dAtA []byte) error

func (*QueryTriggersResponse) XXX_DiscardUnknown 

func (m *QueryTriggersResponse) XXX_DiscardUnknown()

func (*QueryTriggersResponse) XXX_Marshal 

func (m *QueryTriggersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryTriggersResponse) XXX_Merge 

func (m *QueryTriggersResponse) XXX_Merge(src proto.Message)

func (*QueryTriggersResponse) XXX_Size 

func (m *QueryTriggersResponse) XXX_Size() int

func (*QueryTriggersResponse) XXX_Unmarshal 

func (m *QueryTriggersResponse) XXX_Unmarshal(b []byte) error

type QueuedTrigger 

type QueuedTrigger struct {
	// The block height the trigger was detected and queued.
	BlockHeight uint64 `protobuf:"varint,1,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	// The time the trigger was detected and queued.
	Time time.Time `protobuf:"bytes,2,opt,name=time,proto3,stdtime" json:"time"`
	// The trigger that was detected.
	Trigger Trigger `protobuf:"bytes,3,opt,name=trigger,proto3" json:"trigger"`
}

QueuedTrigger

func NewQueuedTrigger 

func NewQueuedTrigger(trigger Trigger, blockTime time.Time, blockHeight uint64) QueuedTrigger

NewQueuedTrigger creates a new trigger for queueing.

func (*QueuedTrigger) Descriptor 

func (*QueuedTrigger) Descriptor() ([]byte, []int)

func (*QueuedTrigger) Equal 

func (this *QueuedTrigger) Equal(that interface{}) bool

func (*QueuedTrigger) GetBlockHeight 

func (m *QueuedTrigger) GetBlockHeight() uint64

func (*QueuedTrigger) GetTime 

func (m *QueuedTrigger) GetTime() time.Time

func (*QueuedTrigger) GetTrigger 

func (m *QueuedTrigger) GetTrigger() Trigger

func (*QueuedTrigger) Marshal 

func (m *QueuedTrigger) Marshal() (dAtA []byte, err error)

func (*QueuedTrigger) MarshalTo 

func (m *QueuedTrigger) MarshalTo(dAtA []byte) (int, error)

func (*QueuedTrigger) MarshalToSizedBuffer 

func (m *QueuedTrigger) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueuedTrigger) ProtoMessage 

func (*QueuedTrigger) ProtoMessage()

func (*QueuedTrigger) Reset 

func (m *QueuedTrigger) Reset()

func (*QueuedTrigger) Size 

func (m *QueuedTrigger) Size() (n int)

func (*QueuedTrigger) String 

func (m *QueuedTrigger) String() string

func (*QueuedTrigger) Unmarshal 

func (m *QueuedTrigger) Unmarshal(dAtA []byte) error

func (QueuedTrigger) UnpackInterfaces 

func (m QueuedTrigger) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (*QueuedTrigger) XXX_DiscardUnknown 

func (m *QueuedTrigger) XXX_DiscardUnknown()

func (*QueuedTrigger) XXX_Marshal 

func (m *QueuedTrigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueuedTrigger) XXX_Merge 

func (m *QueuedTrigger) XXX_Merge(src proto.Message)

func (*QueuedTrigger) XXX_Size 

func (m *QueuedTrigger) XXX_Size() int

func (*QueuedTrigger) XXX_Unmarshal 

func (m *QueuedTrigger) XXX_Unmarshal(b []byte) error

type TransactionEvent 

type TransactionEvent struct {
	// The name of the event for a match.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The attributes that must be present for a match.
	Attributes []Attribute `protobuf:"bytes,2,rep,name=attributes,proto3" json:"attributes"`
}

TransactionEvent

func (*TransactionEvent) Descriptor 

func (*TransactionEvent) Descriptor() ([]byte, []int)

func (*TransactionEvent) Equal 

func (this *TransactionEvent) Equal(that interface{}) bool

func (*TransactionEvent) GetAttributes 

func (m *TransactionEvent) GetAttributes() []Attribute

func (TransactionEvent) GetEventOrder 

func (e TransactionEvent) GetEventOrder() uint64

GetEventOrder gets the order for which this event should be processed

func (TransactionEvent) GetEventPrefix 

func (e TransactionEvent) GetEventPrefix() string

GetEventPrefix gets the prefix for a TransactionEvent.

func (*TransactionEvent) GetName 

func (m *TransactionEvent) GetName() string

func (*TransactionEvent) Marshal 

func (m *TransactionEvent) Marshal() (dAtA []byte, err error)

func (*TransactionEvent) MarshalTo 

func (m *TransactionEvent) MarshalTo(dAtA []byte) (int, error)

func (*TransactionEvent) MarshalToSizedBuffer 

func (m *TransactionEvent) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (TransactionEvent) Matches 

func (e TransactionEvent) Matches(other abci.Event) bool

Matches checks if two TransactionEvents have the same type and matching attributes.

func (*TransactionEvent) ProtoMessage 

func (*TransactionEvent) ProtoMessage()

func (*TransactionEvent) Reset 

func (m *TransactionEvent) Reset()

func (*TransactionEvent) Size 

func (m *TransactionEvent) Size() (n int)

func (*TransactionEvent) String 

func (m *TransactionEvent) String() string

func (*TransactionEvent) Unmarshal 

func (m *TransactionEvent) Unmarshal(dAtA []byte) error

func (TransactionEvent) Validate 

func (e TransactionEvent) Validate() error

Validate checks if the event data is valid.

func (TransactionEvent) ValidateContext 

func (e TransactionEvent) ValidateContext(_ sdk.Context) error

Validate checks if this event is valid with the current context.

func (*TransactionEvent) XXX_DiscardUnknown 

func (m *TransactionEvent) XXX_DiscardUnknown()

func (*TransactionEvent) XXX_Marshal 

func (m *TransactionEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TransactionEvent) XXX_Merge 

func (m *TransactionEvent) XXX_Merge(src proto.Message)

func (*TransactionEvent) XXX_Size 

func (m *TransactionEvent) XXX_Size() int

func (*TransactionEvent) XXX_Unmarshal 

func (m *TransactionEvent) XXX_Unmarshal(b []byte) error

type Trigger 

type Trigger struct {
	// An integer to uniquely identify the trigger.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// The owner of the trigger.
	Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	// The event that must be detected for the trigger to fire.
	Event *types.Any `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`
	// The messages to run when the trigger fires.
	Actions []*types.Any `protobuf:"bytes,4,rep,name=actions,proto3" json:"actions,omitempty"`
}

Trigger

func NewTrigger 

func NewTrigger(id TriggerID, owner string, event *codectypes.Any, action []*codectypes.Any) Trigger

NewTrigger creates a new trigger.

func (*Trigger) Descriptor 

func (*Trigger) Descriptor() ([]byte, []int)

func (*Trigger) Equal 

func (this *Trigger) Equal(that interface{}) bool

func (*Trigger) GetActions 

func (m *Trigger) GetActions() []*types.Any

func (*Trigger) GetEvent 

func (m *Trigger) GetEvent() *types.Any

func (*Trigger) GetId 

func (m *Trigger) GetId() uint64

func (*Trigger) GetOwner 

func (m *Trigger) GetOwner() string

func (Trigger) GetTriggerEventI 

func (m Trigger) GetTriggerEventI() (TriggerEventI, error)

GetTriggerEventI returns unpacked TriggerEvent

func (*Trigger) Marshal 

func (m *Trigger) Marshal() (dAtA []byte, err error)

func (*Trigger) MarshalTo 

func (m *Trigger) MarshalTo(dAtA []byte) (int, error)

func (*Trigger) MarshalToSizedBuffer 

func (m *Trigger) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Trigger) ProtoMessage 

func (*Trigger) ProtoMessage()

func (*Trigger) Reset 

func (m *Trigger) Reset()

func (*Trigger) Size 

func (m *Trigger) Size() (n int)

func (*Trigger) String 

func (m *Trigger) String() string

func (*Trigger) Unmarshal 

func (m *Trigger) Unmarshal(dAtA []byte) error

func (Trigger) UnpackInterfaces 

func (m Trigger) UnpackInterfaces(unpacker codectypes.AnyUnpacker) error

UnpackInterfaces implements UnpackInterfacesMessage.UnpackInterfaces

func (*Trigger) XXX_DiscardUnknown 

func (m *Trigger) XXX_DiscardUnknown()

func (*Trigger) XXX_Marshal 

func (m *Trigger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Trigger) XXX_Merge 

func (m *Trigger) XXX_Merge(src proto.Message)

func (*Trigger) XXX_Size 

func (m *Trigger) XXX_Size() int

func (*Trigger) XXX_Unmarshal 

func (m *Trigger) XXX_Unmarshal(b []byte) error

type TriggerEventI 

type TriggerEventI interface {
	proto.Message
	GetEventPrefix() string
	GetEventOrder() uint64
	Validate() error
	ValidateContext(ctx sdk.Context) error
}

type TriggerID 

type TriggerID = uint64

func GetTriggerIDFromBytes 

func GetTriggerIDFromBytes(bz []byte) TriggerID

GetTriggerIDFromBytes returns triggerID in uint64 format from a byte array

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CreateTrigger 

func (*UnimplementedMsgServer) CreateTrigger(ctx context.Context, req *MsgCreateTriggerRequest) (*MsgCreateTriggerResponse, error)

func (*UnimplementedMsgServer) DestroyTrigger 

func (*UnimplementedMsgServer) DestroyTrigger(ctx context.Context, req *MsgDestroyTriggerRequest) (*MsgDestroyTriggerResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) TriggerByID 

func (*UnimplementedQueryServer) TriggerByID(ctx context.Context, req *QueryTriggerByIDRequest) (*QueryTriggerByIDResponse, error)

func (*UnimplementedQueryServer) Triggers 

func (*UnimplementedQueryServer) Triggers(ctx context.Context, req *QueryTriggersRequest) (*QueryTriggersResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.