pbevents

package
v0.19.0 Latest Latest
Warning

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

 Go to latest Published: Jun 26, 2018 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Bound_BoundType_name = map[int32]string{
	0: "ABSOLUTE",
	1: "RELATIVE",
	2: "FIRST",
	3: "LATEST",
	4: "STREAM",
}
View Source 
var Bound_BoundType_value = map[string]int32{
	"ABSOLUTE": 0,
	"RELATIVE": 1,
	"FIRST":    2,
	"LATEST":   3,
	"STREAM":   4,
}

Functions

func GetEventData 

func GetEventData(ev *events.Event) isExecutionEvent_EventData

func GetTopic 

func GetTopic(topics []binary.Word256) [][]byte

func RegisterEventsServer 

func RegisterEventsServer(s *grpc.Server, srv EventsServer)

func RegisterExecutionEventsServer 

func RegisterExecutionEventsServer(s *grpc.Server, srv ExecutionEventsServer)

Types

type BlockRange 

type BlockRange struct {
	// Bounds can be set to:
	// absolute: block height
	// relative: block height counting back from latest
	// latest: latest block when call is processed
	// stream: for End keep sending new blocks, for start same as latest
	Start                *Bound   `protobuf:"bytes,1,opt,name=Start,proto3" json:"Start,omitempty"`
	End                  *Bound   `protobuf:"bytes,2,opt,name=End,proto3" json:"End,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

An inclusive range of blocks to include in output

func NewBlockRange 

func NewBlockRange(start, end *Bound) *BlockRange

func (*BlockRange) Bounds 

func (br *BlockRange) Bounds(latestBlockHeight uint64) (startKey, endKey events.Key, streaming bool)

func (*BlockRange) Descriptor 

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

func (*BlockRange) GetEnd 

func (m *BlockRange) GetEnd() *Bound

func (*BlockRange) GetStart 

func (m *BlockRange) GetStart() *Bound

func (*BlockRange) ProtoMessage 

func (*BlockRange) ProtoMessage()

func (*BlockRange) Reset 

func (m *BlockRange) Reset()

func (*BlockRange) String 

func (m *BlockRange) String() string

func (*BlockRange) XXX_DiscardUnknown 

func (m *BlockRange) XXX_DiscardUnknown()

func (*BlockRange) XXX_Marshal 

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

func (*BlockRange) XXX_Merge 

func (dst *BlockRange) XXX_Merge(src proto.Message)

func (*BlockRange) XXX_Size 

func (m *BlockRange) XXX_Size() int

func (*BlockRange) XXX_Unmarshal 

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

type Bound 

type Bound struct {
	Type                 Bound_BoundType `protobuf:"varint,1,opt,name=Type,proto3,enum=pbevents.Bound_BoundType" json:"Type,omitempty"`
	Index                uint64          `protobuf:"varint,2,opt,name=Index,proto3" json:"Index,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func AbsoluteBound 

func AbsoluteBound(index uint64) *Bound

func LatestBound 

func LatestBound() *Bound

func RelativeBound 

func RelativeBound(index uint64) *Bound

func StreamBound 

func StreamBound() *Bound

func (*Bound) Bound 

func (b *Bound) Bound(latestBlockHeight uint64) uint64

func (*Bound) Descriptor 

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

func (*Bound) GetIndex 

func (m *Bound) GetIndex() uint64

func (*Bound) GetType 

func (m *Bound) GetType() Bound_BoundType

func (*Bound) Key 

func (b *Bound) Key(latestBlockHeight uint64) events.Key

func (*Bound) ProtoMessage 

func (*Bound) ProtoMessage()

func (*Bound) Reset 

func (m *Bound) Reset()

func (*Bound) String 

func (m *Bound) String() string

func (*Bound) XXX_DiscardUnknown 

func (m *Bound) XXX_DiscardUnknown()

func (*Bound) XXX_Marshal 

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

func (*Bound) XXX_Merge 

func (dst *Bound) XXX_Merge(src proto.Message)

func (*Bound) XXX_Size 

func (m *Bound) XXX_Size() int

func (*Bound) XXX_Unmarshal 

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

type Bound_BoundType 

type Bound_BoundType int32
const (
	// Index is absolute index of object in collection
	Bound_ABSOLUTE Bound_BoundType = 0
	// Index is an offset relative to another bound determined by context
	Bound_RELATIVE Bound_BoundType = 1
	// The first block
	Bound_FIRST Bound_BoundType = 2
	// Ignore provided index and evaluate to latest index
	Bound_LATEST Bound_BoundType = 3
	// Ignore provided index and stream new objects as they are generated
	Bound_STREAM Bound_BoundType = 4
)

func (Bound_BoundType) EnumDescriptor 

func (Bound_BoundType) EnumDescriptor() ([]byte, []int)

func (Bound_BoundType) String 

func (x Bound_BoundType) String() string

type CallData 

type CallData struct {
	Caller               []byte   `protobuf:"bytes,1,opt,name=Caller,proto3" json:"Caller,omitempty"`
	Callee               []byte   `protobuf:"bytes,2,opt,name=Callee,proto3" json:"Callee,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	Value                uint64   `protobuf:"varint,4,opt,name=Value,proto3" json:"Value,omitempty"`
	Gas                  uint64   `protobuf:"varint,5,opt,name=Gas,proto3" json:"Gas,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func GetCallData 

func GetCallData(cd *events.CallData) *CallData

func (*CallData) CallData 

func (cd *CallData) CallData() *events.CallData

func (*CallData) Descriptor 

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

func (*CallData) GetCallee 

func (m *CallData) GetCallee() []byte

func (*CallData) GetCaller 

func (m *CallData) GetCaller() []byte

func (*CallData) GetData 

func (m *CallData) GetData() []byte

func (*CallData) GetGas 

func (m *CallData) GetGas() uint64

func (*CallData) GetValue 

func (m *CallData) GetValue() uint64

func (*CallData) ProtoMessage 

func (*CallData) ProtoMessage()

func (*CallData) Reset 

func (m *CallData) Reset()

func (*CallData) String 

func (m *CallData) String() string

func (*CallData) XXX_DiscardUnknown 

func (m *CallData) XXX_DiscardUnknown()

func (*CallData) XXX_Marshal 

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

func (*CallData) XXX_Merge 

func (dst *CallData) XXX_Merge(src proto.Message)

func (*CallData) XXX_Size 

func (m *CallData) XXX_Size() int

func (*CallData) XXX_Unmarshal 

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

type Event 

type Event struct {
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	// Types that are valid to be assigned to Event:
	//	*Event_ExecutionEvent
	//	*Event_TendermintEventJSON
	Event                isEvent_Event `protobuf_oneof:"Event"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Event) Descriptor 

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

func (*Event) GetEvent 

func (m *Event) GetEvent() isEvent_Event

func (*Event) GetExecutionEvent 

func (m *Event) GetExecutionEvent() *ExecutionEvent

func (*Event) GetName 

func (m *Event) GetName() string

func (*Event) GetTendermintEventJSON 

func (m *Event) GetTendermintEventJSON() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

func (dst *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_OneofFuncs 

func (*Event) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type EventDataCall 

type EventDataCall struct {
	CallData             *CallData         `protobuf:"bytes,1,opt,name=CallData,proto3" json:"CallData,omitempty"`
	Origin               []byte            `protobuf:"bytes,2,opt,name=Origin,proto3" json:"Origin,omitempty"`
	StackDepth           uint64            `protobuf:"varint,3,opt,name=StackDepth,proto3" json:"StackDepth,omitempty"`
	Return               []byte            `protobuf:"bytes,4,opt,name=Return,proto3" json:"Return,omitempty"`
	Exception            *errors.Exception `protobuf:"bytes,5,opt,name=Exception,proto3" json:"Exception,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func GetEventDataCall 

func GetEventDataCall(edt *events.EventDataCall) *EventDataCall

func (*EventDataCall) Call 

func (call *EventDataCall) Call(txHash []byte) *events.EventDataCall

func (*EventDataCall) Descriptor 

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

func (*EventDataCall) GetCallData 

func (m *EventDataCall) GetCallData() *CallData

func (*EventDataCall) GetException 

func (m *EventDataCall) GetException() *errors.Exception

func (*EventDataCall) GetOrigin 

func (m *EventDataCall) GetOrigin() []byte

func (*EventDataCall) GetReturn 

func (m *EventDataCall) GetReturn() []byte

func (*EventDataCall) GetStackDepth 

func (m *EventDataCall) GetStackDepth() uint64

func (*EventDataCall) ProtoMessage 

func (*EventDataCall) ProtoMessage()

func (*EventDataCall) Reset 

func (m *EventDataCall) Reset()

func (*EventDataCall) String 

func (m *EventDataCall) String() string

func (*EventDataCall) XXX_DiscardUnknown 

func (m *EventDataCall) XXX_DiscardUnknown()

func (*EventDataCall) XXX_Marshal 

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

func (*EventDataCall) XXX_Merge 

func (dst *EventDataCall) XXX_Merge(src proto.Message)

func (*EventDataCall) XXX_Size 

func (m *EventDataCall) XXX_Size() int

func (*EventDataCall) XXX_Unmarshal 

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

type EventDataLog 

type EventDataLog struct {
	Address              []byte   `protobuf:"bytes,1,opt,name=Address,proto3" json:"Address,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=Data,proto3" json:"Data,omitempty"`
	Topics               [][]byte `protobuf:"bytes,3,rep,name=Topics,proto3" json:"Topics,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventDataLog) Descriptor 

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

func (*EventDataLog) GetAddress 

func (m *EventDataLog) GetAddress() []byte

func (*EventDataLog) GetData 

func (m *EventDataLog) GetData() []byte

func (*EventDataLog) GetTopics 

func (m *EventDataLog) GetTopics() [][]byte

func (*EventDataLog) Log 

func (log *EventDataLog) Log(height uint64) *events.EventDataLog

func (*EventDataLog) ProtoMessage 

func (*EventDataLog) ProtoMessage()

func (*EventDataLog) Reset 

func (m *EventDataLog) Reset()

func (*EventDataLog) String 

func (m *EventDataLog) String() string

func (*EventDataLog) XXX_DiscardUnknown 

func (m *EventDataLog) XXX_DiscardUnknown()

func (*EventDataLog) XXX_Marshal 

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

func (*EventDataLog) XXX_Merge 

func (dst *EventDataLog) XXX_Merge(src proto.Message)

func (*EventDataLog) XXX_Size 

func (m *EventDataLog) XXX_Size() int

func (*EventDataLog) XXX_Unmarshal 

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

type EventDataTx 

type EventDataTx struct {
	Return               []byte            `protobuf:"bytes,1,opt,name=Return,proto3" json:"Return,omitempty"`
	Exception            *errors.Exception `protobuf:"bytes,2,opt,name=Exception,proto3" json:"Exception,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*EventDataTx) Descriptor 

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

func (*EventDataTx) GetException 

func (m *EventDataTx) GetException() *errors.Exception

func (*EventDataTx) GetReturn 

func (m *EventDataTx) GetReturn() []byte

func (*EventDataTx) ProtoMessage 

func (*EventDataTx) ProtoMessage()

func (*EventDataTx) Reset 

func (m *EventDataTx) Reset()

func (*EventDataTx) String 

func (m *EventDataTx) String() string

func (*EventDataTx) Tx 

func (tx *EventDataTx) Tx() *events.EventDataTx

func (*EventDataTx) XXX_DiscardUnknown 

func (m *EventDataTx) XXX_DiscardUnknown()

func (*EventDataTx) XXX_Marshal 

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

func (*EventDataTx) XXX_Merge 

func (dst *EventDataTx) XXX_Merge(src proto.Message)

func (*EventDataTx) XXX_Size 

func (m *EventDataTx) XXX_Size() int

func (*EventDataTx) XXX_Unmarshal 

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

type EventHeader 

type EventHeader struct {
	// Transaction type
	TxType string `protobuf:"bytes,1,opt,name=TxType,proto3" json:"TxType,omitempty"`
	// The hash of the transaction that caused this event to be generated
	TxHash []byte `protobuf:"bytes,2,opt,name=TxHash,proto3" json:"TxHash,omitempty"`
	// The type of event
	EventType string `protobuf:"bytes,3,opt,name=EventType,proto3" json:"EventType,omitempty"`
	// EventID published with event
	EventID string `protobuf:"bytes,4,opt,name=EventID,proto3" json:"EventID,omitempty"`
	// The block height at which this event was emitted
	Height uint64 `protobuf:"varint,5,opt,name=Height,proto3" json:"Height,omitempty"`
	// The index amongst all other events in the block of this event
	Index                uint64   `protobuf:"varint,6,opt,name=Index,proto3" json:"Index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func GetEventHeader 

func GetEventHeader(header *events.Header) *EventHeader

func (*EventHeader) Descriptor 

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

func (*EventHeader) GetEventID 

func (m *EventHeader) GetEventID() string

func (*EventHeader) GetEventType 

func (m *EventHeader) GetEventType() string

func (*EventHeader) GetHeight 

func (m *EventHeader) GetHeight() uint64

func (*EventHeader) GetIndex 

func (m *EventHeader) GetIndex() uint64

func (*EventHeader) GetTxHash 

func (m *EventHeader) GetTxHash() []byte

func (*EventHeader) GetTxType 

func (m *EventHeader) GetTxType() string

func (*EventHeader) Header 

func (h *EventHeader) Header() *events.Header

func (*EventHeader) Key 

func (h *EventHeader) Key() events.Key

func (*EventHeader) ProtoMessage 

func (*EventHeader) ProtoMessage()

func (*EventHeader) Reset 

func (m *EventHeader) Reset()

func (*EventHeader) String 

func (m *EventHeader) String() string

func (*EventHeader) XXX_DiscardUnknown 

func (m *EventHeader) XXX_DiscardUnknown()

func (*EventHeader) XXX_Marshal 

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

func (*EventHeader) XXX_Merge 

func (dst *EventHeader) XXX_Merge(src proto.Message)

func (*EventHeader) XXX_Size 

func (m *EventHeader) XXX_Size() int

func (*EventHeader) XXX_Unmarshal 

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

type EventIdParam 

type EventIdParam struct {
	EventId              string   `protobuf:"bytes,1,opt,name=eventId,proto3" json:"eventId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Params

func (*EventIdParam) Descriptor 

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

func (*EventIdParam) GetEventId 

func (m *EventIdParam) GetEventId() string

func (*EventIdParam) ProtoMessage 

func (*EventIdParam) ProtoMessage()

func (*EventIdParam) Reset 

func (m *EventIdParam) Reset()

func (*EventIdParam) String 

func (m *EventIdParam) String() string

func (*EventIdParam) XXX_DiscardUnknown 

func (m *EventIdParam) XXX_DiscardUnknown()

func (*EventIdParam) XXX_Marshal 

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

func (*EventIdParam) XXX_Merge 

func (dst *EventIdParam) XXX_Merge(src proto.Message)

func (*EventIdParam) XXX_Size 

func (m *EventIdParam) XXX_Size() int

func (*EventIdParam) XXX_Unmarshal 

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

type EventUnSub 

type EventUnSub struct {
	Result               bool     `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Results

func (*EventUnSub) Descriptor 

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

func (*EventUnSub) GetResult 

func (m *EventUnSub) GetResult() bool

func (*EventUnSub) ProtoMessage 

func (*EventUnSub) ProtoMessage()

func (*EventUnSub) Reset 

func (m *EventUnSub) Reset()

func (*EventUnSub) String 

func (m *EventUnSub) String() string

func (*EventUnSub) XXX_DiscardUnknown 

func (m *EventUnSub) XXX_DiscardUnknown()

func (*EventUnSub) XXX_Marshal 

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

func (*EventUnSub) XXX_Merge 

func (dst *EventUnSub) XXX_Merge(src proto.Message)

func (*EventUnSub) XXX_Size 

func (m *EventUnSub) XXX_Size() int

func (*EventUnSub) XXX_Unmarshal 

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

type Event_ExecutionEvent 

type Event_ExecutionEvent struct {
	ExecutionEvent *ExecutionEvent `protobuf:"bytes,2,opt,name=ExecutionEvent,proto3,oneof"`
}

type Event_TendermintEventJSON 

type Event_TendermintEventJSON struct {
	TendermintEventJSON string `protobuf:"bytes,3,opt,name=TendermintEventJSON,proto3,oneof"`
}

type EventsClient 

type EventsClient interface {
	EventPoll(ctx context.Context, in *SubIdParam, opts ...grpc.CallOption) (*PollResponse, error)
	EventSubscribe(ctx context.Context, in *EventIdParam, opts ...grpc.CallOption) (*SubIdParam, error)
	EventUnsubscribe(ctx context.Context, in *SubIdParam, opts ...grpc.CallOption) (*EventUnSub, error)
}

EventsClient is the client API for Events service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewEventsClient 

func NewEventsClient(cc *grpc.ClientConn) EventsClient

type EventsServer 

type EventsServer interface {
	EventPoll(context.Context, *SubIdParam) (*PollResponse, error)
	EventSubscribe(context.Context, *EventIdParam) (*SubIdParam, error)
	EventUnsubscribe(context.Context, *SubIdParam) (*EventUnSub, error)
}

EventsServer is the server API for Events service.

type ExecutionEvent 

type ExecutionEvent struct {
	Header *EventHeader `protobuf:"bytes,1,opt,name=Header,proto3" json:"Header,omitempty"`
	// Types that are valid to be assigned to EventData:
	//	*ExecutionEvent_EventDataTx
	//	*ExecutionEvent_EventDataCall
	//	*ExecutionEvent_EventDataLog
	EventData            isExecutionEvent_EventData `protobuf_oneof:"EventData"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func GetExecutionEvent 

func GetExecutionEvent(event *events.Event) *ExecutionEvent

func (*ExecutionEvent) Descriptor 

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

func (*ExecutionEvent) Event 

func (ee *ExecutionEvent) Event() *events.Event

func (*ExecutionEvent) GetEventData 

func (m *ExecutionEvent) GetEventData() isExecutionEvent_EventData

func (*ExecutionEvent) GetEventDataCall 

func (m *ExecutionEvent) GetEventDataCall() *EventDataCall

func (*ExecutionEvent) GetEventDataLog 

func (m *ExecutionEvent) GetEventDataLog() *EventDataLog

func (*ExecutionEvent) GetEventDataTx 

func (m *ExecutionEvent) GetEventDataTx() *EventDataTx

func (*ExecutionEvent) GetHeader 

func (m *ExecutionEvent) GetHeader() *EventHeader

func (*ExecutionEvent) Key 

func (ee *ExecutionEvent) Key() events.Key

func (*ExecutionEvent) ProtoMessage 

func (*ExecutionEvent) ProtoMessage()

func (*ExecutionEvent) Reset 

func (m *ExecutionEvent) Reset()

func (*ExecutionEvent) String 

func (m *ExecutionEvent) String() string

func (*ExecutionEvent) XXX_DiscardUnknown 

func (m *ExecutionEvent) XXX_DiscardUnknown()

func (*ExecutionEvent) XXX_Marshal 

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

func (*ExecutionEvent) XXX_Merge 

func (dst *ExecutionEvent) XXX_Merge(src proto.Message)

func (*ExecutionEvent) XXX_OneofFuncs 

func (*ExecutionEvent) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ExecutionEvent) XXX_Size 

func (m *ExecutionEvent) XXX_Size() int

func (*ExecutionEvent) XXX_Unmarshal 

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

type ExecutionEvent_EventDataCall 

type ExecutionEvent_EventDataCall struct {
	EventDataCall *EventDataCall `protobuf:"bytes,3,opt,name=EventDataCall,proto3,oneof"`
}

type ExecutionEvent_EventDataLog 

type ExecutionEvent_EventDataLog struct {
	EventDataLog *EventDataLog `protobuf:"bytes,4,opt,name=EventDataLog,proto3,oneof"`
}

type ExecutionEvent_EventDataTx 

type ExecutionEvent_EventDataTx struct {
	EventDataTx *EventDataTx `protobuf:"bytes,2,opt,name=EventDataTx,proto3,oneof"`
}

type ExecutionEventsClient 

type ExecutionEventsClient interface {
	// GetEvents provides events streaming one block at a time - that is all events emitted in a particular block
	// are guaranteed to be delivered in each GetEventsResponse
	GetEvents(ctx context.Context, in *GetEventsRequest, opts ...grpc.CallOption) (ExecutionEvents_GetEventsClient, error)
}

ExecutionEventsClient is the client API for ExecutionEvents service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewExecutionEventsClient 

func NewExecutionEventsClient(cc *grpc.ClientConn) ExecutionEventsClient

type ExecutionEventsServer 

type ExecutionEventsServer interface {
	// GetEvents provides events streaming one block at a time - that is all events emitted in a particular block
	// are guaranteed to be delivered in each GetEventsResponse
	GetEvents(*GetEventsRequest, ExecutionEvents_GetEventsServer) error
}

ExecutionEventsServer is the server API for ExecutionEvents service.

type ExecutionEvents_GetEventsClient 

type ExecutionEvents_GetEventsClient interface {
	Recv() (*GetEventsResponse, error)
	grpc.ClientStream
}

type ExecutionEvents_GetEventsServer 

type ExecutionEvents_GetEventsServer interface {
	Send(*GetEventsResponse) error
	grpc.ServerStream
}

type GetEventsRequest 

type GetEventsRequest struct {
	BlockRange *BlockRange `protobuf:"bytes,1,opt,name=BlockRange,proto3" json:"BlockRange,omitempty"`
	// Specify a query on which to match the tags of events.
	// Tag        | Match type | Values
	// -----------------------------------------
	//   All events
	// -----------------------------------------
	// TxType       | String     | "UnknownTx", "SendTx", "CallTx", "NameTx", "BondTx", "UnbondTx", "PermissionsTx", "GovernanceTx"
	// TxHash       | String     | bytes
	// EventType    | String     | "CallEvent", "LogEvent", "AccountInputEvent", "AccountOutputEvent"
	// EventID      | String     | string
	// Height       | Integer    | uint64
	// Index        | Integer    | uint64
	// MessageType  | String     | Go type name
	// -----------------------------------------
	//   Log event
	// -----------------------------------------
	// Address      | String     | Address (hex)
	// Log<0-4>     | String     | Word256 (hex)
	// Log<0-4>Text | String     | string (trimmed)
	// -----------------------------------------
	//   Call event
	// -----------------------------------------
	// Origin       | String     | Address (hex)
	// Callee       | String     | Address (hex)
	// Caller       | String     | Address (hex)
	// Value        | Integer    | uint64
	// Gas          | Integer    | uint64
	// StackDepth   | Integer    | uint64
	// Exception    | String     | string
	// -----------------------------------------
	//   Tx event (input/output)
	// -----------------------------------------
	// Exception  | String     | string
	//
	// For example:
	// EventType = 'LogEvent' AND EventID CONTAINS 'bar' AND TxHash = '020304' AND Height >= 34 AND Index < 3 AND Address = 'DEADBEEFDEADBEEFDEADBEEFDEADBEEFDEADBEEF'
	Query                string   `protobuf:"bytes,2,opt,name=Query,proto3" json:"Query,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetEventsRequest) Descriptor 

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

func (*GetEventsRequest) GetBlockRange 

func (m *GetEventsRequest) GetBlockRange() *BlockRange

func (*GetEventsRequest) GetQuery 

func (m *GetEventsRequest) GetQuery() string

func (*GetEventsRequest) ProtoMessage 

func (*GetEventsRequest) ProtoMessage()

func (*GetEventsRequest) Reset 

func (m *GetEventsRequest) Reset()

func (*GetEventsRequest) String 

func (m *GetEventsRequest) String() string

func (*GetEventsRequest) XXX_DiscardUnknown 

func (m *GetEventsRequest) XXX_DiscardUnknown()

func (*GetEventsRequest) XXX_Marshal 

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

func (*GetEventsRequest) XXX_Merge 

func (dst *GetEventsRequest) XXX_Merge(src proto.Message)

func (*GetEventsRequest) XXX_Size 

func (m *GetEventsRequest) XXX_Size() int

func (*GetEventsRequest) XXX_Unmarshal 

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

type GetEventsResponse 

type GetEventsResponse struct {
	Events               []*ExecutionEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*GetEventsResponse) Descriptor 

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

func (*GetEventsResponse) GetEvents 

func (m *GetEventsResponse) GetEvents() []*ExecutionEvent

func (*GetEventsResponse) ProtoMessage 

func (*GetEventsResponse) ProtoMessage()

func (*GetEventsResponse) Reset 

func (m *GetEventsResponse) Reset()

func (*GetEventsResponse) String 

func (m *GetEventsResponse) String() string

func (*GetEventsResponse) XXX_DiscardUnknown 

func (m *GetEventsResponse) XXX_DiscardUnknown()

func (*GetEventsResponse) XXX_Marshal 

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

func (*GetEventsResponse) XXX_Merge 

func (dst *GetEventsResponse) XXX_Merge(src proto.Message)

func (*GetEventsResponse) XXX_Size 

func (m *GetEventsResponse) XXX_Size() int

func (*GetEventsResponse) XXX_Unmarshal 

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

type PollResponse 

type PollResponse struct {
	Events               []*Event `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PollResponse) Descriptor 

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

func (*PollResponse) GetEvents 

func (m *PollResponse) GetEvents() []*Event

func (*PollResponse) ProtoMessage 

func (*PollResponse) ProtoMessage()

func (*PollResponse) Reset 

func (m *PollResponse) Reset()

func (*PollResponse) String 

func (m *PollResponse) String() string

func (*PollResponse) XXX_DiscardUnknown 

func (m *PollResponse) XXX_DiscardUnknown()

func (*PollResponse) XXX_Marshal 

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

func (*PollResponse) XXX_Merge 

func (dst *PollResponse) XXX_Merge(src proto.Message)

func (*PollResponse) XXX_Size 

func (m *PollResponse) XXX_Size() int

func (*PollResponse) XXX_Unmarshal 

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

type SubIdParam 

type SubIdParam struct {
	SubId                string   `protobuf:"bytes,1,opt,name=subId,proto3" json:"subId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubIdParam) Descriptor 

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

func (*SubIdParam) GetSubId 

func (m *SubIdParam) GetSubId() string

func (*SubIdParam) ProtoMessage 

func (*SubIdParam) ProtoMessage()

func (*SubIdParam) Reset 

func (m *SubIdParam) Reset()

func (*SubIdParam) String 

func (m *SubIdParam) String() string

func (*SubIdParam) XXX_DiscardUnknown 

func (m *SubIdParam) XXX_DiscardUnknown()

func (*SubIdParam) XXX_Marshal 

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

func (*SubIdParam) XXX_Merge 

func (dst *SubIdParam) XXX_Merge(src proto.Message)

func (*SubIdParam) XXX_Size 

func (m *SubIdParam) XXX_Size() int

func (*SubIdParam) XXX_Unmarshal 

func (m *SubIdParam) XXX_Unmarshal(b []byte) 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.