Help us shape the future of Go! Take the 2026 Go Developer Survey

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL