event_provider_apipb

type ABCIAttribute struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type ABCIEvent struct {
	Type       string           `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Attributes []*ABCIAttribute `protobuf:"bytes,2,rep,name=attributes,proto3" json:"attributes,omitempty"`
	// contains filtered or unexported fields
}

type ABCIResponseDeliverTx struct {
	Code      int32        `protobuf:"zigzag32,1,opt,name=code,proto3" json:"code,omitempty"`
	Log       string       `protobuf:"bytes,2,opt,name=log,proto3" json:"log,omitempty"`
	Info      string       `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	GasWanted int64        `protobuf:"zigzag64,4,opt,name=gas_wanted,json=gasWanted,proto3" json:"gas_wanted,omitempty"`
	GasUsed   int64        `protobuf:"zigzag64,5,opt,name=gas_used,json=gasUsed,proto3" json:"gas_used,omitempty"`
	Events    []*ABCIEvent `protobuf:"bytes,6,rep,name=events,proto3" json:"events,omitempty"`
	Codespace string       `protobuf:"bytes,7,opt,name=codespace,proto3" json:"codespace,omitempty"`
	TxHash    []byte       `protobuf:"bytes,8,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	// contains filtered or unexported fields
}

type BasicBlockInfo struct {

	// Block height
	Height int64 `protobuf:"zigzag64,1,opt,name=height,proto3" json:"height,omitempty"`
	// Block timestamp in UNIX millis.
	Timestamp int64 `protobuf:"zigzag64,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Block time in RFC3339 format.
	Time string `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

type Block struct {
	Height  int64  `protobuf:"zigzag64,1,opt,name=height,proto3" json:"height,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// Processed block events in the block
	Events []*BlockEvent `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"`
	// Indicates whether the block is the latest one available in the event provider
	InSync bool `protobuf:"varint,4,opt,name=in_sync,json=inSync,proto3" json:"in_sync,omitempty"`
	// Block timestamp in UNIX millis.
	Time int64 `protobuf:"zigzag64,5,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

type BlockEvent struct {

	// Event type
	TypeUrl string `protobuf:"bytes,1,opt,name=type_url,json=typeUrl,proto3" json:"type_url,omitempty"`
	// Event data
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// TX hash
	TxHash []byte `protobuf:"bytes,3,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	// Set only if it's a BeginBlock or EndBlock event
	Mode string `protobuf:"bytes,4,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

type BlockEventsRPC struct {

	// Array of event types
	Types []string `protobuf:"bytes,1,rep,name=types,proto3" json:"types,omitempty"`
	// Array of parsed events
	Events [][]byte `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// Map of event index - tx hash
	TxHashes map[int32][]byte `` /* 176-byte string literal not displayed */
	// contains filtered or unexported fields
}

type EventProviderAPIClient interface {
	// Get latest block from event provider
	GetLatestHeight(ctx context.Context, in *GetLatestHeightRequest, opts ...grpc.CallOption) (*GetLatestHeightResponse, error)
	// Stream latest block information
	StreamLatestHeight(ctx context.Context, in *StreamLatestHeightRequest, opts ...grpc.CallOption) (EventProviderAPI_StreamLatestHeightClient, error)
	// Stream processed block events for selected backend
	StreamBlockEvents(ctx context.Context, in *StreamBlockEventsRequest, opts ...grpc.CallOption) (EventProviderAPI_StreamBlockEventsClient, error)
	// Get processed block events for selected backend
	GetBlockEventsRPC(ctx context.Context, in *GetBlockEventsRPCRequest, opts ...grpc.CallOption) (*GetBlockEventsRPCResponse, error)
	// Get custom processed block events for selected backend
	GetCustomEventsRPC(ctx context.Context, in *GetCustomEventsRPCRequest, opts ...grpc.CallOption) (*GetCustomEventsRPCResponse, error)
	// Get raw block events for selected height
	GetABCIBlockEvents(ctx context.Context, in *GetABCIBlockEventsRequest, opts ...grpc.CallOption) (*GetABCIBlockEventsResponse, error)
	// Get all raw block events for selected height
	GetABCIBlockEventsAtHeight(ctx context.Context, in *GetABCIBlockEventsAtHeightRequest, opts ...grpc.CallOption) (*GetABCIBlockEventsAtHeightResponse, error)
	// Stream raw block events for selected height
	StreamABCIEvents(ctx context.Context, in *StreamABCIEventsRequest, opts ...grpc.CallOption) (EventProviderAPI_StreamABCIEventsClient, error)
}

type EventProviderAPIServer interface {
	// Get latest block from event provider
	GetLatestHeight(context.Context, *GetLatestHeightRequest) (*GetLatestHeightResponse, error)
	// Stream latest block information
	StreamLatestHeight(*StreamLatestHeightRequest, EventProviderAPI_StreamLatestHeightServer) error
	// Stream processed block events for selected backend
	StreamBlockEvents(*StreamBlockEventsRequest, EventProviderAPI_StreamBlockEventsServer) error
	// Get processed block events for selected backend
	GetBlockEventsRPC(context.Context, *GetBlockEventsRPCRequest) (*GetBlockEventsRPCResponse, error)
	// Get custom processed block events for selected backend
	GetCustomEventsRPC(context.Context, *GetCustomEventsRPCRequest) (*GetCustomEventsRPCResponse, error)
	// Get raw block events for selected height
	GetABCIBlockEvents(context.Context, *GetABCIBlockEventsRequest) (*GetABCIBlockEventsResponse, error)
	// Get all raw block events for selected height
	GetABCIBlockEventsAtHeight(context.Context, *GetABCIBlockEventsAtHeightRequest) (*GetABCIBlockEventsAtHeightResponse, error)
	// Stream raw block events for selected height
	StreamABCIEvents(*StreamABCIEventsRequest, EventProviderAPI_StreamABCIEventsServer) error
	// contains filtered or unexported methods
}

type EventProviderAPI_StreamABCIEventsClient interface {
	Recv() (*StreamABCIEventsResponse, error)
	grpc.ClientStream
}

type EventProviderAPI_StreamABCIEventsServer interface {
	Send(*StreamABCIEventsResponse) error
	grpc.ServerStream
}

type EventProviderAPI_StreamBlockEventsClient interface {
	Recv() (*StreamBlockEventsResponse, error)
	grpc.ClientStream
}

type EventProviderAPI_StreamBlockEventsServer interface {
	Send(*StreamBlockEventsResponse) error
	grpc.ServerStream
}

type EventProviderAPI_StreamLatestHeightClient interface {
	Recv() (*StreamLatestHeightResponse, error)
	grpc.ClientStream
}

type EventProviderAPI_StreamLatestHeightServer interface {
	Send(*StreamLatestHeightResponse) error
	grpc.ServerStream
}

type GetABCIBlockEventsAtHeightRequest struct {
	Height int32 `protobuf:"zigzag32,1,opt,name=height,proto3" json:"height,omitempty"`
	// contains filtered or unexported fields
}

type GetABCIBlockEventsAtHeightResponse struct {

	// Response version.
	V string `protobuf:"bytes,1,opt,name=v,proto3" json:"v,omitempty"`
	// Status of the response.
	S string `protobuf:"bytes,2,opt,name=s,proto3" json:"s,omitempty"`
	// Error message.
	E        string    `protobuf:"bytes,3,opt,name=e,proto3" json:"e,omitempty"`
	RawBlock *RawBlock `protobuf:"bytes,4,opt,name=raw_block,json=rawBlock,proto3" json:"raw_block,omitempty"`
	// contains filtered or unexported fields
}

type GetABCIBlockEventsRequest struct {
	Height int32 `protobuf:"zigzag32,1,opt,name=height,proto3" json:"height,omitempty"`
	// Array of event types
	EventTypes []string `protobuf:"bytes,2,rep,name=event_types,json=eventTypes,proto3" json:"event_types,omitempty"`
	// contains filtered or unexported fields
}

type GetABCIBlockEventsResponse struct {

	// Response version.
	V string `protobuf:"bytes,1,opt,name=v,proto3" json:"v,omitempty"`
	// Status of the response.
	S string `protobuf:"bytes,2,opt,name=s,proto3" json:"s,omitempty"`
	// Error message.
	E        string    `protobuf:"bytes,3,opt,name=e,proto3" json:"e,omitempty"`
	RawBlock *RawBlock `protobuf:"bytes,4,opt,name=raw_block,json=rawBlock,proto3" json:"raw_block,omitempty"`
	// contains filtered or unexported fields
}

type GetBlockEventsRPCRequest struct {

	// Select backend processor
	Backend       string `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
	Height        int32  `protobuf:"zigzag32,2,opt,name=height,proto3" json:"height,omitempty"`
	HumanReadable bool   `protobuf:"varint,3,opt,name=human_readable,json=humanReadable,proto3" json:"human_readable,omitempty"`
	// contains filtered or unexported fields
}

type GetBlockEventsRPCResponse struct {

	// Response version.
	V string `protobuf:"bytes,1,opt,name=v,proto3" json:"v,omitempty"`
	// Status of the response.
	S string `protobuf:"bytes,2,opt,name=s,proto3" json:"s,omitempty"`
	// Error message.
	E     string          `protobuf:"bytes,3,opt,name=e,proto3" json:"e,omitempty"`
	Data  *BlockEventsRPC `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Block *BasicBlockInfo `protobuf:"bytes,5,opt,name=block,proto3" json:"block,omitempty"`
	// contains filtered or unexported fields
}

type GetCustomEventsRPCRequest struct {

	// Select backend processor
	Backend string `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
	Height  int32  `protobuf:"zigzag32,2,opt,name=height,proto3" json:"height,omitempty"`
	// Specify custom events to get
	Events string `protobuf:"bytes,3,opt,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type GetCustomEventsRPCResponse struct {

	// Response version.
	V string `protobuf:"bytes,1,opt,name=v,proto3" json:"v,omitempty"`
	// Status of the response.
	S string `protobuf:"bytes,2,opt,name=s,proto3" json:"s,omitempty"`
	// Error message.
	E     string          `protobuf:"bytes,3,opt,name=e,proto3" json:"e,omitempty"`
	Data  *BlockEventsRPC `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Block *BasicBlockInfo `protobuf:"bytes,5,opt,name=block,proto3" json:"block,omitempty"`
	// contains filtered or unexported fields
}

type GetLatestHeightRequest struct {
	// contains filtered or unexported fields
}

type GetLatestHeightResponse struct {

	// Response version.
	V string `protobuf:"bytes,1,opt,name=v,proto3" json:"v,omitempty"`
	// Status of the response.
	S string `protobuf:"bytes,2,opt,name=s,proto3" json:"s,omitempty"`
	// Error message.
	E    string             `protobuf:"bytes,3,opt,name=e,proto3" json:"e,omitempty"`
	Data *LatestBlockHeight `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type LatestBlockHeight struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Time   int64  `protobuf:"zigzag64,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

type RawBlock struct {
	Height    int64  `protobuf:"zigzag64,1,opt,name=height,proto3" json:"height,omitempty"`
	BlockTime string `protobuf:"bytes,5,opt,name=block_time,json=blockTime,proto3" json:"block_time,omitempty"`
	// Block timestamp in UNIX millis.
	BlockTimestamp   int64                    `protobuf:"zigzag64,6,opt,name=block_timestamp,json=blockTimestamp,proto3" json:"block_timestamp,omitempty"`
	TxsResults       []*ABCIResponseDeliverTx `protobuf:"bytes,2,rep,name=txs_results,json=txsResults,proto3" json:"txs_results,omitempty"`
	BeginBlockEvents []*ABCIEvent             `protobuf:"bytes,3,rep,name=begin_block_events,json=beginBlockEvents,proto3" json:"begin_block_events,omitempty"`
	EndBlockEvents   []*ABCIEvent             `protobuf:"bytes,4,rep,name=end_block_events,json=endBlockEvents,proto3" json:"end_block_events,omitempty"`
	// contains filtered or unexported fields
}

type StreamABCIEventsRequest struct {
	Height int32 `protobuf:"zigzag32,1,opt,name=height,proto3" json:"height,omitempty"`
	// Array of event types
	EventTypes []string `protobuf:"bytes,2,rep,name=event_types,json=eventTypes,proto3" json:"event_types,omitempty"`
	// Number of blocks to include in each stream response. The service will have a
	// cap on the batch size, and default to it if it's greater. Once the stream is
	// in sync, the batch size
	BatchSize uint32 `protobuf:"varint,3,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// Number of parallel fetchers. The service will have a cap on the number of
	// fetchers, and default to it. The service may chose to throttle the fetchers
	// based on the current load.
	Fetchers uint32 `protobuf:"varint,4,opt,name=fetchers,proto3" json:"fetchers,omitempty"`
	// contains filtered or unexported fields
}

type StreamABCIEventsResponse struct {
	Blocks []*StreamedRawBlock `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

type StreamBlockEventsRequest struct {

	// Select backend processor
	Backend string `protobuf:"bytes,1,opt,name=backend,proto3" json:"backend,omitempty"`
	Height  int32  `protobuf:"zigzag32,2,opt,name=height,proto3" json:"height,omitempty"`
	// Comma separated list of events to get
	Events string `protobuf:"bytes,3,opt,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type StreamBlockEventsResponse struct {
	Blocks []*Block `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

type StreamLatestHeightRequest struct {
	// contains filtered or unexported fields
}

type StreamLatestHeightResponse struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Time   int64  `protobuf:"zigzag64,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

type StreamedRawBlock struct {

	// Indicates whether the block is the latest one available in the event provider
	InSync    bool   `protobuf:"varint,20,opt,name=in_sync,json=inSync,proto3" json:"in_sync,omitempty"`
	Height    int64  `protobuf:"zigzag64,1,opt,name=height,proto3" json:"height,omitempty"`
	BlockTime string `protobuf:"bytes,5,opt,name=block_time,json=blockTime,proto3" json:"block_time,omitempty"`
	// Block timestamp in UNIX millis.
	BlockTimestamp   int64                    `protobuf:"zigzag64,6,opt,name=block_timestamp,json=blockTimestamp,proto3" json:"block_timestamp,omitempty"`
	TxsResults       []*ABCIResponseDeliverTx `protobuf:"bytes,2,rep,name=txs_results,json=txsResults,proto3" json:"txs_results,omitempty"`
	BeginBlockEvents []*ABCIEvent             `protobuf:"bytes,3,rep,name=begin_block_events,json=beginBlockEvents,proto3" json:"begin_block_events,omitempty"`
	EndBlockEvents   []*ABCIEvent             `protobuf:"bytes,4,rep,name=end_block_events,json=endBlockEvents,proto3" json:"end_block_events,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedEventProviderAPIServer struct {
}

type UnsafeEventProviderAPIServer interface {
	// contains filtered or unexported methods
}