rpcevents

Feb 27, 2019

Changes in this version

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

type BlockRange

+ func AbsoluteRange(start, end uint64) *BlockRange

+ func SingleBlock(height uint64) *BlockRange

+ type EventsResponse struct

+ Events []*exec.Event

+ Height uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*EventsResponse) ProtoMessage()

+ func (*EventsResponse) XXX_MessageName() string

+ func (dst *EventsResponse) XXX_Merge(src proto.Message)

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

+ func (m *EventsResponse) GetHeight() uint64

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

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

+ func (m *EventsResponse) Reset()

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

+ func (m *EventsResponse) String() string

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

+ func (m *EventsResponse) XXX_DiscardUnknown()

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

+ func (m *EventsResponse) XXX_Size() int

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

type ExecutionEventsClient

+ Events func(ctx context.Context, in *BlocksRequest, opts ...grpc.CallOption) (ExecutionEvents_EventsClient, error)

+ Stream func(ctx context.Context, in *BlocksRequest, opts ...grpc.CallOption) (ExecutionEvents_StreamClient, error)

+ Tx func(ctx context.Context, in *TxRequest, opts ...grpc.CallOption) (*exec.TxExecution, error)

type ExecutionEventsServer

+ Events func(*BlocksRequest, ExecutionEvents_EventsServer) error

+ Stream func(*BlocksRequest, ExecutionEvents_StreamServer) error

+ Tx func(context.Context, *TxRequest) (*exec.TxExecution, error)

+ type ExecutionEvents_EventsClient interface

+ Recv func() (*EventsResponse, error)

+ type ExecutionEvents_EventsServer interface

+ Send func(*EventsResponse) error

+ type ExecutionEvents_StreamClient interface

+ Recv func() (*exec.StreamEvent, error)

+ type ExecutionEvents_StreamServer interface

+ Send func(*exec.StreamEvent) error

+ type GetTxsRequest struct

+ EndHeight uint64

+ Query string

+ StartHeight uint64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetTxsRequest) ProtoMessage()

+ func (*GetTxsRequest) XXX_MessageName() string

+ func (dst *GetTxsRequest) XXX_Merge(src proto.Message)

+ func (m *GetTxsRequest) GetEndHeight() uint64

+ func (m *GetTxsRequest) GetQuery() string

+ func (m *GetTxsRequest) GetStartHeight() uint64

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

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

+ func (m *GetTxsRequest) Reset()

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

+ func (m *GetTxsRequest) String() string

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

+ func (m *GetTxsRequest) XXX_DiscardUnknown()

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

+ func (m *GetTxsRequest) XXX_Size() int

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

type Provider

+ IterateStreamEvents func(start, end exec.StreamKey, consumer func(*exec.StreamEvent) error) (err error)

+ TxByHash func(txHash []byte) (*exec.TxExecution, error)

+ type TxRequest struct

+ TxHash github_com_hyperledger_burrow_binary.HexBytes

+ Wait bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*TxRequest) ProtoMessage()

+ func (*TxRequest) XXX_MessageName() string

+ func (dst *TxRequest) XXX_Merge(src proto.Message)

+ func (m *TxRequest) GetWait() bool

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

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

+ func (m *TxRequest) Reset()

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

+ func (m *TxRequest) String() string

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

+ func (m *TxRequest) XXX_DiscardUnknown()

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

+ func (m *TxRequest) XXX_Size() int

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

Nov 9, 2018

Changes in this version

type BlockRange

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ 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 BlocksRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *BlocksRequest) XXX_Merge(src proto.Message)

+ func (m *BlocksRequest) XXX_DiscardUnknown()

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

+ func (m *BlocksRequest) XXX_Size() int

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

type Bound

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ 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 GetBlockRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *GetBlockRequest) XXX_Merge(src proto.Message)

+ func (m *GetBlockRequest) XXX_DiscardUnknown()

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

+ func (m *GetBlockRequest) XXX_Size() int

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

type GetEventsResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ 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 GetTxRequest

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *GetTxRequest) XXX_Merge(src proto.Message)

+ func (m *GetTxRequest) XXX_DiscardUnknown()

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

+ func (m *GetTxRequest) XXX_Size() int

+ func (m *GetTxRequest) XXX_Unmarshal(b []byte) error

type GetTxsResponse

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (dst *GetTxsResponse) XXX_Merge(src proto.Message)

+ func (m *GetTxsResponse) XXX_DiscardUnknown()

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

+ func (m *GetTxsResponse) XXX_Size() int

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

Jul 24, 2018

Changes in this version

+ const SubscribeBufferSize

+ var Bound_BoundType_name = map[int32]string

+ var Bound_BoundType_value = map[string]int32

+ var ErrIntOverflowRpcevents = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthRpcevents = fmt.Errorf("proto: negative length found during unmarshaling")

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

+ type BlockRange struct

+ End *Bound

+ Start *Bound

+ func NewBlockRange(start, end *Bound) *BlockRange

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

+ func (*BlockRange) ProtoMessage()

+ func (*BlockRange) XXX_MessageName() string

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

+ func (m *BlockRange) GetEnd() *Bound

+ func (m *BlockRange) GetStart() *Bound

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

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

+ func (m *BlockRange) Reset()

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

+ func (m *BlockRange) String() string

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

+ type BlocksRequest struct

+ BlockRange *BlockRange

+ Query string

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

+ func (*BlocksRequest) ProtoMessage()

+ func (*BlocksRequest) XXX_MessageName() string

+ func (m *BlocksRequest) GetBlockRange() *BlockRange

+ func (m *BlocksRequest) GetQuery() string

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

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

+ func (m *BlocksRequest) Reset()

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

+ func (m *BlocksRequest) String() string

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

+ type Bound struct

+ Index uint64

+ Type Bound_BoundType

+ 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 (*Bound) XXX_MessageName() string

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

+ func (m *Bound) GetIndex() uint64

+ func (m *Bound) GetType() Bound_BoundType

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

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

+ func (m *Bound) Reset()

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

+ func (m *Bound) String() string

+ func (m *Bound) Unmarshal(dAtA []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 ExecutionEventsClient interface

+ GetBlock func(ctx context.Context, in *GetBlockRequest, opts ...grpc.CallOption) (*exec.BlockExecution, error)

+ GetBlocks func(ctx context.Context, in *BlocksRequest, opts ...grpc.CallOption) (ExecutionEvents_GetBlocksClient, error)

+ GetEvents func(ctx context.Context, in *BlocksRequest, opts ...grpc.CallOption) (ExecutionEvents_GetEventsClient, error)

+ GetTx func(ctx context.Context, in *GetTxRequest, opts ...grpc.CallOption) (*exec.TxExecution, error)

+ GetTxs func(ctx context.Context, in *BlocksRequest, opts ...grpc.CallOption) (ExecutionEvents_GetTxsClient, error)

+ func NewExecutionEventsClient(cc *grpc.ClientConn) ExecutionEventsClient

+ type ExecutionEventsServer interface

+ GetBlock func(context.Context, *GetBlockRequest) (*exec.BlockExecution, error)

+ GetBlocks func(*BlocksRequest, ExecutionEvents_GetBlocksServer) error

+ GetEvents func(*BlocksRequest, ExecutionEvents_GetEventsServer) error

+ GetTx func(context.Context, *GetTxRequest) (*exec.TxExecution, error)

+ GetTxs func(*BlocksRequest, ExecutionEvents_GetTxsServer) error

+ type ExecutionEvents_GetBlocksClient interface

+ Recv func() (*exec.BlockExecution, error)

+ type ExecutionEvents_GetBlocksServer interface

+ Send func(*exec.BlockExecution) error

+ type ExecutionEvents_GetEventsClient interface

+ Recv func() (*GetEventsResponse, error)

+ type ExecutionEvents_GetEventsServer interface

+ Send func(*GetEventsResponse) error

+ type ExecutionEvents_GetTxsClient interface

+ Recv func() (*GetTxsResponse, error)

+ type ExecutionEvents_GetTxsServer interface

+ Send func(*GetTxsResponse) error

+ type GetBlockRequest struct

+ Height uint64

+ Wait bool

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

+ func (*GetBlockRequest) ProtoMessage()

+ func (*GetBlockRequest) XXX_MessageName() string

+ func (m *GetBlockRequest) GetHeight() uint64

+ func (m *GetBlockRequest) GetWait() bool

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

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

+ func (m *GetBlockRequest) Reset()

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

+ func (m *GetBlockRequest) String() string

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

+ type GetEventsResponse struct

+ Events []*exec.Event

+ Height uint64

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

+ func (*GetEventsResponse) ProtoMessage()

+ func (*GetEventsResponse) XXX_MessageName() string

+ func (m *GetEventsResponse) GetEvents() []*exec.Event

+ func (m *GetEventsResponse) GetHeight() uint64

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

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

+ func (m *GetEventsResponse) Reset()

+ func (m *GetEventsResponse) Size() (n int)

+ func (m *GetEventsResponse) String() string

+ func (m *GetEventsResponse) Unmarshal(dAtA []byte) error

+ type GetTxRequest struct

+ TxHash github_com_hyperledger_burrow_binary.HexBytes

+ Wait bool

+ func (*GetTxRequest) Descriptor() ([]byte, []int)

+ func (*GetTxRequest) ProtoMessage()

+ func (*GetTxRequest) XXX_MessageName() string

+ func (m *GetTxRequest) GetWait() bool

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

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

+ func (m *GetTxRequest) Reset()

+ func (m *GetTxRequest) Size() (n int)

+ func (m *GetTxRequest) String() string

+ func (m *GetTxRequest) Unmarshal(dAtA []byte) error

+ type GetTxsResponse struct

+ Height uint64

+ TxExecutions []*exec.TxExecution

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

+ func (*GetTxsResponse) ProtoMessage()

+ func (*GetTxsResponse) XXX_MessageName() string

+ func (m *GetTxsResponse) GetHeight() uint64

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

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

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

+ func (m *GetTxsResponse) Reset()

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

+ func (m *GetTxsResponse) String() string

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

+ type Provider interface

+ GetBlock func(height uint64) (*exec.BlockExecution, error)

+ GetBlocks func(startHeight, endHeight uint64, consumer func(*exec.BlockExecution) (stop bool)) (stopped bool, err error)

+ GetTx func(txHash []byte) (*exec.TxExecution, error)

Jun 26, 2018

Changes in this version

+ func NewEventsServer(subscriptions *rpc.Subscriptions) pbevents.EventsServer

+ func NewExecutionEventsServer(eventsProvider events.Provider, emitter event.Emitter, tip bcm.TipInfo) pbevents.ExecutionEventsServer