Documentation

Index

Constants

View Source
const SubscribeBufferSize = 100

Variables

View Source
var (
	ErrInvalidLengthRpcevents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpcevents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRpcevents = fmt.Errorf("proto: unexpected end of group")
)
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 ConsumeBlockExecutions

func ConsumeBlockExecutions(stream ExecutionEvents_StreamClient, consumer func(*exec.BlockExecution) error,
	continuityOptions ...exec.ContinuityOpt) error

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 AbsoluteRange

    func AbsoluteRange(start, end uint64) *BlockRange

    func NewBlockRange

    func NewBlockRange(start, end *Bound) *BlockRange

    func SingleBlock

    func SingleBlock(height uint64) *BlockRange

    func (*BlockRange) Bounds

    func (br *BlockRange) Bounds(latestBlockHeight uint64) (startHeight, endHeight uint64, streaming bool)

      Get bounds suitable for events.Provider

      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) Marshal

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

      func (*BlockRange) MarshalTo

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

      func (*BlockRange) MarshalToSizedBuffer

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

      func (*BlockRange) ProtoMessage

      func (*BlockRange) ProtoMessage()

      func (*BlockRange) Reset

      func (m *BlockRange) Reset()

      func (*BlockRange) Size

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

      func (*BlockRange) String

      func (m *BlockRange) String() string

      func (*BlockRange) Unmarshal

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

      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 (m *BlockRange) XXX_Merge(src proto.Message)

      func (*BlockRange) XXX_MessageName

      func (*BlockRange) XXX_MessageName() string

      func (*BlockRange) XXX_Size

      func (m *BlockRange) XXX_Size() int

      func (*BlockRange) XXX_Unmarshal

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

      type BlocksRequest

      type BlocksRequest 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 (*BlocksRequest) Descriptor

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

      func (*BlocksRequest) GetBlockRange

      func (m *BlocksRequest) GetBlockRange() *BlockRange

      func (*BlocksRequest) GetQuery

      func (m *BlocksRequest) GetQuery() string

      func (*BlocksRequest) Marshal

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

      func (*BlocksRequest) MarshalTo

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

      func (*BlocksRequest) MarshalToSizedBuffer

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

      func (*BlocksRequest) ProtoMessage

      func (*BlocksRequest) ProtoMessage()

      func (*BlocksRequest) Reset

      func (m *BlocksRequest) Reset()

      func (*BlocksRequest) Size

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

      func (*BlocksRequest) String

      func (m *BlocksRequest) String() string

      func (*BlocksRequest) Unmarshal

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

      func (*BlocksRequest) XXX_DiscardUnknown

      func (m *BlocksRequest) XXX_DiscardUnknown()

      func (*BlocksRequest) XXX_Marshal

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

      func (*BlocksRequest) XXX_Merge

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

      func (*BlocksRequest) XXX_MessageName

      func (*BlocksRequest) XXX_MessageName() string

      func (*BlocksRequest) XXX_Size

      func (m *BlocksRequest) XXX_Size() int

      func (*BlocksRequest) XXX_Unmarshal

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

      type Bound

      type Bound struct {
      	Type                 Bound_BoundType `protobuf:"varint,1,opt,name=Type,proto3,enum=rpcevents.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) Marshal

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

      func (*Bound) MarshalTo

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

      func (*Bound) MarshalToSizedBuffer

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

      func (*Bound) ProtoMessage

      func (*Bound) ProtoMessage()

      func (*Bound) Reset

      func (m *Bound) Reset()

      func (*Bound) Size

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

      func (*Bound) String

      func (m *Bound) String() string

      func (*Bound) Unmarshal

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

      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 (m *Bound) XXX_Merge(src proto.Message)

      func (*Bound) XXX_MessageName

      func (*Bound) XXX_MessageName() string

      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 an item
      	Bound_ABSOLUTE Bound_BoundType = 0
      	// Index is an offset relative to last item
      	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 EventsResponse

      type EventsResponse struct {
      	Height               uint64        `protobuf:"varint,1,opt,name=Height,proto3" json:"Height,omitempty"`
      	Events               []*exec.Event `protobuf:"bytes,2,rep,name=Events,proto3" json:"Events,omitempty"`
      	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
      	XXX_unrecognized     []byte        `json:"-"`
      	XXX_sizecache        int32         `json:"-"`
      }

      func (*EventsResponse) Descriptor

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

      func (*EventsResponse) GetEvents

      func (m *EventsResponse) GetEvents() []*exec.Event

      func (*EventsResponse) GetHeight

      func (m *EventsResponse) GetHeight() uint64

      func (*EventsResponse) Marshal

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

      func (*EventsResponse) MarshalTo

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

      func (*EventsResponse) MarshalToSizedBuffer

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

      func (*EventsResponse) ProtoMessage

      func (*EventsResponse) ProtoMessage()

      func (*EventsResponse) Reset

      func (m *EventsResponse) Reset()

      func (*EventsResponse) Size

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

      func (*EventsResponse) String

      func (m *EventsResponse) String() string

      func (*EventsResponse) Unmarshal

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

      func (*EventsResponse) XXX_DiscardUnknown

      func (m *EventsResponse) XXX_DiscardUnknown()

      func (*EventsResponse) XXX_Marshal

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

      func (*EventsResponse) XXX_Merge

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

      func (*EventsResponse) XXX_MessageName

      func (*EventsResponse) XXX_MessageName() string

      func (*EventsResponse) XXX_Size

      func (m *EventsResponse) XXX_Size() int

      func (*EventsResponse) XXX_Unmarshal

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

      type ExecutionEventsClient

      type ExecutionEventsClient interface {
      	// Get StreamEvents (including transactions) for a range of block heights
      	Stream(ctx context.Context, in *BlocksRequest, opts ...grpc.CallOption) (ExecutionEvents_StreamClient, error)
      	// Get a particular TxExecution by hash
      	Tx(ctx context.Context, in *TxRequest, opts ...grpc.CallOption) (*exec.TxExecution, error)
      	// 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
      	Events(ctx context.Context, in *BlocksRequest, opts ...grpc.CallOption) (ExecutionEvents_EventsClient, 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 {
        	// Get StreamEvents (including transactions) for a range of block heights
        	Stream(*BlocksRequest, ExecutionEvents_StreamServer) error
        	// Get a particular TxExecution by hash
        	Tx(context.Context, *TxRequest) (*exec.TxExecution, error)
        	// 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
        	Events(*BlocksRequest, ExecutionEvents_EventsServer) error
        }

          ExecutionEventsServer is the server API for ExecutionEvents service.

          func NewExecutionEventsServer

          func NewExecutionEventsServer(eventsProvider Provider, emitter *event.Emitter,
          	tip bcm.BlockchainInfo, logger *logging.Logger) ExecutionEventsServer

          type ExecutionEvents_EventsClient

          type ExecutionEvents_EventsClient interface {
          	Recv() (*EventsResponse, error)
          	grpc.ClientStream
          }

          type ExecutionEvents_EventsServer

          type ExecutionEvents_EventsServer interface {
          	Send(*EventsResponse) error
          	grpc.ServerStream
          }

          type ExecutionEvents_StreamClient

          type ExecutionEvents_StreamClient interface {
          	Recv() (*exec.StreamEvent, error)
          	grpc.ClientStream
          }

          type ExecutionEvents_StreamServer

          type ExecutionEvents_StreamServer interface {
          	Send(*exec.StreamEvent) error
          	grpc.ServerStream
          }

          type GetBlockRequest

          type GetBlockRequest struct {
          	// Height of block required
          	Height uint64 `protobuf:"varint,1,opt,name=Height,proto3" json:"Height,omitempty"`
          	// Whether to wait for the block to become available
          	Wait                 bool     `protobuf:"varint,2,opt,name=Wait,proto3" json:"Wait,omitempty"`
          	XXX_NoUnkeyedLiteral struct{} `json:"-"`
          	XXX_unrecognized     []byte   `json:"-"`
          	XXX_sizecache        int32    `json:"-"`
          }

          func (*GetBlockRequest) Descriptor

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

          func (*GetBlockRequest) GetHeight

          func (m *GetBlockRequest) GetHeight() uint64

          func (*GetBlockRequest) GetWait

          func (m *GetBlockRequest) GetWait() bool

          func (*GetBlockRequest) Marshal

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

          func (*GetBlockRequest) MarshalTo

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

          func (*GetBlockRequest) MarshalToSizedBuffer

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

          func (*GetBlockRequest) ProtoMessage

          func (*GetBlockRequest) ProtoMessage()

          func (*GetBlockRequest) Reset

          func (m *GetBlockRequest) Reset()

          func (*GetBlockRequest) Size

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

          func (*GetBlockRequest) String

          func (m *GetBlockRequest) String() string

          func (*GetBlockRequest) Unmarshal

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

          func (*GetBlockRequest) XXX_DiscardUnknown

          func (m *GetBlockRequest) XXX_DiscardUnknown()

          func (*GetBlockRequest) XXX_Marshal

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

          func (*GetBlockRequest) XXX_Merge

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

          func (*GetBlockRequest) XXX_MessageName

          func (*GetBlockRequest) XXX_MessageName() string

          func (*GetBlockRequest) XXX_Size

          func (m *GetBlockRequest) XXX_Size() int

          func (*GetBlockRequest) XXX_Unmarshal

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

          type GetTxsRequest

          type GetTxsRequest struct {
          	StartHeight          uint64   `protobuf:"varint,1,opt,name=StartHeight,proto3" json:"StartHeight,omitempty"`
          	EndHeight            uint64   `protobuf:"varint,2,opt,name=EndHeight,proto3" json:"EndHeight,omitempty"`
          	Query                string   `protobuf:"bytes,3,opt,name=Query,proto3" json:"Query,omitempty"`
          	XXX_NoUnkeyedLiteral struct{} `json:"-"`
          	XXX_unrecognized     []byte   `json:"-"`
          	XXX_sizecache        int32    `json:"-"`
          }

          func (*GetTxsRequest) Descriptor

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

          func (*GetTxsRequest) GetEndHeight

          func (m *GetTxsRequest) GetEndHeight() uint64

          func (*GetTxsRequest) GetQuery

          func (m *GetTxsRequest) GetQuery() string

          func (*GetTxsRequest) GetStartHeight

          func (m *GetTxsRequest) GetStartHeight() uint64

          func (*GetTxsRequest) Marshal

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

          func (*GetTxsRequest) MarshalTo

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

          func (*GetTxsRequest) MarshalToSizedBuffer

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

          func (*GetTxsRequest) ProtoMessage

          func (*GetTxsRequest) ProtoMessage()

          func (*GetTxsRequest) Reset

          func (m *GetTxsRequest) Reset()

          func (*GetTxsRequest) Size

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

          func (*GetTxsRequest) String

          func (m *GetTxsRequest) String() string

          func (*GetTxsRequest) Unmarshal

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

          func (*GetTxsRequest) XXX_DiscardUnknown

          func (m *GetTxsRequest) XXX_DiscardUnknown()

          func (*GetTxsRequest) XXX_Marshal

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

          func (*GetTxsRequest) XXX_Merge

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

          func (*GetTxsRequest) XXX_MessageName

          func (*GetTxsRequest) XXX_MessageName() string

          func (*GetTxsRequest) XXX_Size

          func (m *GetTxsRequest) XXX_Size() int

          func (*GetTxsRequest) XXX_Unmarshal

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

          type GetTxsResponse

          type GetTxsResponse struct {
          	Height               uint64              `protobuf:"varint,1,opt,name=Height,proto3" json:"Height,omitempty"`
          	TxExecutions         []*exec.TxExecution `protobuf:"bytes,2,rep,name=TxExecutions,proto3" json:"TxExecutions,omitempty"`
          	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
          	XXX_unrecognized     []byte              `json:"-"`
          	XXX_sizecache        int32               `json:"-"`
          }

          func (*GetTxsResponse) Descriptor

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

          func (*GetTxsResponse) GetHeight

          func (m *GetTxsResponse) GetHeight() uint64

          func (*GetTxsResponse) GetTxExecutions

          func (m *GetTxsResponse) GetTxExecutions() []*exec.TxExecution

          func (*GetTxsResponse) Marshal

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

          func (*GetTxsResponse) MarshalTo

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

          func (*GetTxsResponse) MarshalToSizedBuffer

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

          func (*GetTxsResponse) ProtoMessage

          func (*GetTxsResponse) ProtoMessage()

          func (*GetTxsResponse) Reset

          func (m *GetTxsResponse) Reset()

          func (*GetTxsResponse) Size

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

          func (*GetTxsResponse) String

          func (m *GetTxsResponse) String() string

          func (*GetTxsResponse) Unmarshal

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

          func (*GetTxsResponse) XXX_DiscardUnknown

          func (m *GetTxsResponse) XXX_DiscardUnknown()

          func (*GetTxsResponse) XXX_Marshal

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

          func (*GetTxsResponse) XXX_Merge

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

          func (*GetTxsResponse) XXX_MessageName

          func (*GetTxsResponse) XXX_MessageName() string

          func (*GetTxsResponse) XXX_Size

          func (m *GetTxsResponse) XXX_Size() int

          func (*GetTxsResponse) XXX_Unmarshal

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

          type Provider

          type Provider interface {
          	// Get transactions
          	IterateStreamEvents(startHeight, endHeight *uint64, sortOrder storage.SortOrder,
          		consumer func(*exec.StreamEvent) error) (err error)
          	// Get a particular TxExecution by hash
          	TxByHash(txHash []byte) (*exec.TxExecution, error)
          }

          type TxRequest

          type TxRequest struct {
          	// Height of block required
          	TxHash github_com_hyperledger_burrow_binary.HexBytes `protobuf:"bytes,1,opt,name=TxHash,proto3,customtype=github.com/hyperledger/burrow/binary.HexBytes" json:"TxHash"`
          	// Whether to wait for the block to become available
          	Wait                 bool     `protobuf:"varint,2,opt,name=Wait,proto3" json:"Wait,omitempty"`
          	XXX_NoUnkeyedLiteral struct{} `json:"-"`
          	XXX_unrecognized     []byte   `json:"-"`
          	XXX_sizecache        int32    `json:"-"`
          }

          func (*TxRequest) Descriptor

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

          func (*TxRequest) GetWait

          func (m *TxRequest) GetWait() bool

          func (*TxRequest) Marshal

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

          func (*TxRequest) MarshalTo

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

          func (*TxRequest) MarshalToSizedBuffer

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

          func (*TxRequest) ProtoMessage

          func (*TxRequest) ProtoMessage()

          func (*TxRequest) Reset

          func (m *TxRequest) Reset()

          func (*TxRequest) Size

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

          func (*TxRequest) String

          func (m *TxRequest) String() string

          func (*TxRequest) Unmarshal

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

          func (*TxRequest) XXX_DiscardUnknown

          func (m *TxRequest) XXX_DiscardUnknown()

          func (*TxRequest) XXX_Marshal

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

          func (*TxRequest) XXX_Merge

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

          func (*TxRequest) XXX_MessageName

          func (*TxRequest) XXX_MessageName() string

          func (*TxRequest) XXX_Size

          func (m *TxRequest) XXX_Size() int

          func (*TxRequest) XXX_Unmarshal

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

          type UnimplementedExecutionEventsServer

          type UnimplementedExecutionEventsServer struct {
          }

            UnimplementedExecutionEventsServer can be embedded to have forward compatible implementations.

            func (*UnimplementedExecutionEventsServer) Events

            func (*UnimplementedExecutionEventsServer) Stream

            func (*UnimplementedExecutionEventsServer) Tx