Versions in this module Expand all Collapse all v0 v0.19.0 Jun 26, 2018 Changes in this version + var Bound_BoundType_name = map[int32]string + var Bound_BoundType_value = map[string]int32 + func GetEventData(ev *events.Event) isExecutionEvent_EventData + func GetTopic(topics []binary.Word256) [][]byte + func RegisterEventsServer(s *grpc.Server, srv EventsServer) + func RegisterExecutionEventsServer(s *grpc.Server, srv ExecutionEventsServer) + type BlockRange struct + End *Bound + Start *Bound + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func NewBlockRange(start, end *Bound) *BlockRange + func (*BlockRange) Descriptor() ([]byte, []int) + func (*BlockRange) ProtoMessage() + func (br *BlockRange) Bounds(latestBlockHeight uint64) (startKey, endKey events.Key, streaming bool) + func (dst *BlockRange) XXX_Merge(src proto.Message) + func (m *BlockRange) GetEnd() *Bound + func (m *BlockRange) GetStart() *Bound + func (m *BlockRange) Reset() + func (m *BlockRange) String() string + func (m *BlockRange) XXX_DiscardUnknown() + func (m *BlockRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BlockRange) XXX_Size() int + func (m *BlockRange) XXX_Unmarshal(b []byte) error + type Bound struct + Index uint64 + Type Bound_BoundType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func AbsoluteBound(index uint64) *Bound + func LatestBound() *Bound + func RelativeBound(index uint64) *Bound + func StreamBound() *Bound + func (*Bound) Descriptor() ([]byte, []int) + func (*Bound) ProtoMessage() + func (b *Bound) Bound(latestBlockHeight uint64) uint64 + func (b *Bound) Key(latestBlockHeight uint64) events.Key + func (dst *Bound) XXX_Merge(src proto.Message) + func (m *Bound) GetIndex() uint64 + func (m *Bound) GetType() Bound_BoundType + func (m *Bound) Reset() + func (m *Bound) String() string + func (m *Bound) XXX_DiscardUnknown() + func (m *Bound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Bound) XXX_Size() int + func (m *Bound) XXX_Unmarshal(b []byte) error + type Bound_BoundType int32 + const Bound_ABSOLUTE + const Bound_FIRST + const Bound_LATEST + const Bound_RELATIVE + const Bound_STREAM + func (Bound_BoundType) EnumDescriptor() ([]byte, []int) + func (x Bound_BoundType) String() string + type CallData struct + Callee []byte + Caller []byte + Data []byte + Gas uint64 + Value uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func GetCallData(cd *events.CallData) *CallData + func (*CallData) Descriptor() ([]byte, []int) + func (*CallData) ProtoMessage() + func (cd *CallData) CallData() *events.CallData + func (dst *CallData) XXX_Merge(src proto.Message) + func (m *CallData) GetCallee() []byte + func (m *CallData) GetCaller() []byte + func (m *CallData) GetData() []byte + func (m *CallData) GetGas() uint64 + func (m *CallData) GetValue() uint64 + func (m *CallData) Reset() + func (m *CallData) String() string + func (m *CallData) XXX_DiscardUnknown() + func (m *CallData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CallData) XXX_Size() int + func (m *CallData) XXX_Unmarshal(b []byte) error + type Event struct + Event isEvent_Event + Name string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (*Event) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (dst *Event) XXX_Merge(src proto.Message) + func (m *Event) GetEvent() isEvent_Event + func (m *Event) GetExecutionEvent() *ExecutionEvent + func (m *Event) GetName() string + func (m *Event) GetTendermintEventJSON() string + func (m *Event) Reset() + func (m *Event) String() string + func (m *Event) XXX_DiscardUnknown() + func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Event) XXX_Size() int + func (m *Event) XXX_Unmarshal(b []byte) error + type EventDataCall struct + CallData *CallData + Exception *errors.Exception + Origin []byte + Return []byte + StackDepth uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func GetEventDataCall(edt *events.EventDataCall) *EventDataCall + func (*EventDataCall) Descriptor() ([]byte, []int) + func (*EventDataCall) ProtoMessage() + func (call *EventDataCall) Call(txHash []byte) *events.EventDataCall + func (dst *EventDataCall) XXX_Merge(src proto.Message) + func (m *EventDataCall) GetCallData() *CallData + func (m *EventDataCall) GetException() *errors.Exception + func (m *EventDataCall) GetOrigin() []byte + func (m *EventDataCall) GetReturn() []byte + func (m *EventDataCall) GetStackDepth() uint64 + func (m *EventDataCall) Reset() + func (m *EventDataCall) String() string + func (m *EventDataCall) XXX_DiscardUnknown() + func (m *EventDataCall) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventDataCall) XXX_Size() int + func (m *EventDataCall) XXX_Unmarshal(b []byte) error + type EventDataLog struct + Address []byte + Data []byte + Topics [][]byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EventDataLog) Descriptor() ([]byte, []int) + func (*EventDataLog) ProtoMessage() + func (dst *EventDataLog) XXX_Merge(src proto.Message) + func (log *EventDataLog) Log(height uint64) *events.EventDataLog + func (m *EventDataLog) GetAddress() []byte + func (m *EventDataLog) GetData() []byte + func (m *EventDataLog) GetTopics() [][]byte + func (m *EventDataLog) Reset() + func (m *EventDataLog) String() string + func (m *EventDataLog) XXX_DiscardUnknown() + func (m *EventDataLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventDataLog) XXX_Size() int + func (m *EventDataLog) XXX_Unmarshal(b []byte) error + type EventDataTx struct + Exception *errors.Exception + Return []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EventDataTx) Descriptor() ([]byte, []int) + func (*EventDataTx) ProtoMessage() + func (dst *EventDataTx) XXX_Merge(src proto.Message) + func (m *EventDataTx) GetException() *errors.Exception + func (m *EventDataTx) GetReturn() []byte + func (m *EventDataTx) Reset() + func (m *EventDataTx) String() string + func (m *EventDataTx) XXX_DiscardUnknown() + func (m *EventDataTx) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventDataTx) XXX_Size() int + func (m *EventDataTx) XXX_Unmarshal(b []byte) error + func (tx *EventDataTx) Tx() *events.EventDataTx + type EventHeader struct + EventID string + EventType string + Height uint64 + Index uint64 + TxHash []byte + TxType string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func GetEventHeader(header *events.Header) *EventHeader + func (*EventHeader) Descriptor() ([]byte, []int) + func (*EventHeader) ProtoMessage() + func (dst *EventHeader) XXX_Merge(src proto.Message) + func (h *EventHeader) Header() *events.Header + func (h *EventHeader) Key() events.Key + func (m *EventHeader) GetEventID() string + func (m *EventHeader) GetEventType() string + func (m *EventHeader) GetHeight() uint64 + func (m *EventHeader) GetIndex() uint64 + func (m *EventHeader) GetTxHash() []byte + func (m *EventHeader) GetTxType() string + func (m *EventHeader) Reset() + func (m *EventHeader) String() string + func (m *EventHeader) XXX_DiscardUnknown() + func (m *EventHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventHeader) XXX_Size() int + func (m *EventHeader) XXX_Unmarshal(b []byte) error + type EventIdParam struct + EventId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EventIdParam) Descriptor() ([]byte, []int) + func (*EventIdParam) ProtoMessage() + func (dst *EventIdParam) XXX_Merge(src proto.Message) + func (m *EventIdParam) GetEventId() string + func (m *EventIdParam) Reset() + func (m *EventIdParam) String() string + func (m *EventIdParam) XXX_DiscardUnknown() + func (m *EventIdParam) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventIdParam) XXX_Size() int + func (m *EventIdParam) XXX_Unmarshal(b []byte) error + type EventUnSub struct + Result bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*EventUnSub) Descriptor() ([]byte, []int) + func (*EventUnSub) ProtoMessage() + func (dst *EventUnSub) XXX_Merge(src proto.Message) + func (m *EventUnSub) GetResult() bool + func (m *EventUnSub) Reset() + func (m *EventUnSub) String() string + func (m *EventUnSub) XXX_DiscardUnknown() + func (m *EventUnSub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EventUnSub) XXX_Size() int + func (m *EventUnSub) XXX_Unmarshal(b []byte) error + type Event_ExecutionEvent struct + ExecutionEvent *ExecutionEvent + type Event_TendermintEventJSON struct + TendermintEventJSON string + type EventsClient interface + EventPoll func(ctx context.Context, in *SubIdParam, opts ...grpc.CallOption) (*PollResponse, error) + EventSubscribe func(ctx context.Context, in *EventIdParam, opts ...grpc.CallOption) (*SubIdParam, error) + EventUnsubscribe func(ctx context.Context, in *SubIdParam, opts ...grpc.CallOption) (*EventUnSub, error) + func NewEventsClient(cc *grpc.ClientConn) EventsClient + type EventsServer interface + EventPoll func(context.Context, *SubIdParam) (*PollResponse, error) + EventSubscribe func(context.Context, *EventIdParam) (*SubIdParam, error) + EventUnsubscribe func(context.Context, *SubIdParam) (*EventUnSub, error) + type ExecutionEvent struct + EventData isExecutionEvent_EventData + Header *EventHeader + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func GetExecutionEvent(event *events.Event) *ExecutionEvent + func (*ExecutionEvent) Descriptor() ([]byte, []int) + func (*ExecutionEvent) ProtoMessage() + func (*ExecutionEvent) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + func (dst *ExecutionEvent) XXX_Merge(src proto.Message) + func (ee *ExecutionEvent) Event() *events.Event + func (ee *ExecutionEvent) Key() events.Key + func (m *ExecutionEvent) GetEventData() isExecutionEvent_EventData + func (m *ExecutionEvent) GetEventDataCall() *EventDataCall + func (m *ExecutionEvent) GetEventDataLog() *EventDataLog + func (m *ExecutionEvent) GetEventDataTx() *EventDataTx + func (m *ExecutionEvent) GetHeader() *EventHeader + func (m *ExecutionEvent) Reset() + func (m *ExecutionEvent) String() string + func (m *ExecutionEvent) XXX_DiscardUnknown() + func (m *ExecutionEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ExecutionEvent) XXX_Size() int + func (m *ExecutionEvent) XXX_Unmarshal(b []byte) error + type ExecutionEvent_EventDataCall struct + EventDataCall *EventDataCall + type ExecutionEvent_EventDataLog struct + EventDataLog *EventDataLog + type ExecutionEvent_EventDataTx struct + EventDataTx *EventDataTx + type ExecutionEventsClient interface + GetEvents func(ctx context.Context, in *GetEventsRequest, opts ...grpc.CallOption) (ExecutionEvents_GetEventsClient, error) + func NewExecutionEventsClient(cc *grpc.ClientConn) ExecutionEventsClient + type ExecutionEventsServer interface + GetEvents func(*GetEventsRequest, ExecutionEvents_GetEventsServer) error + type ExecutionEvents_GetEventsClient interface + Recv func() (*GetEventsResponse, error) + type ExecutionEvents_GetEventsServer interface + Send func(*GetEventsResponse) error + type GetEventsRequest struct + BlockRange *BlockRange + Query string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetEventsRequest) Descriptor() ([]byte, []int) + func (*GetEventsRequest) ProtoMessage() + func (dst *GetEventsRequest) XXX_Merge(src proto.Message) + func (m *GetEventsRequest) GetBlockRange() *BlockRange + func (m *GetEventsRequest) GetQuery() string + func (m *GetEventsRequest) Reset() + func (m *GetEventsRequest) String() string + func (m *GetEventsRequest) XXX_DiscardUnknown() + func (m *GetEventsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetEventsRequest) XXX_Size() int + func (m *GetEventsRequest) XXX_Unmarshal(b []byte) error + type GetEventsResponse struct + Events []*ExecutionEvent + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetEventsResponse) Descriptor() ([]byte, []int) + func (*GetEventsResponse) ProtoMessage() + func (dst *GetEventsResponse) XXX_Merge(src proto.Message) + func (m *GetEventsResponse) GetEvents() []*ExecutionEvent + func (m *GetEventsResponse) Reset() + func (m *GetEventsResponse) String() string + func (m *GetEventsResponse) XXX_DiscardUnknown() + func (m *GetEventsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetEventsResponse) XXX_Size() int + func (m *GetEventsResponse) XXX_Unmarshal(b []byte) error + type PollResponse struct + Events []*Event + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PollResponse) Descriptor() ([]byte, []int) + func (*PollResponse) ProtoMessage() + func (dst *PollResponse) XXX_Merge(src proto.Message) + func (m *PollResponse) GetEvents() []*Event + func (m *PollResponse) Reset() + func (m *PollResponse) String() string + func (m *PollResponse) XXX_DiscardUnknown() + func (m *PollResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PollResponse) XXX_Size() int + func (m *PollResponse) XXX_Unmarshal(b []byte) error + type SubIdParam struct + SubId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SubIdParam) Descriptor() ([]byte, []int) + func (*SubIdParam) ProtoMessage() + func (dst *SubIdParam) XXX_Merge(src proto.Message) + func (m *SubIdParam) GetSubId() string + func (m *SubIdParam) Reset() + func (m *SubIdParam) String() string + func (m *SubIdParam) XXX_DiscardUnknown() + func (m *SubIdParam) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SubIdParam) XXX_Size() int + func (m *SubIdParam) XXX_Unmarshal(b []byte) error