event_provider_apipb

package
v1.56.0 Latest Latest
Warning

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

 Go to latest Published: Feb 10, 2025 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var EventProviderAPI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "event_provider_api.EventProviderAPI",
	HandlerType: (*EventProviderAPIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetLatestHeight",
			Handler:    _EventProviderAPI_GetLatestHeight_Handler,
		},
		{
			MethodName: "GetBlockEventsRPC",
			Handler:    _EventProviderAPI_GetBlockEventsRPC_Handler,
		},
		{
			MethodName: "GetCustomEventsRPC",
			Handler:    _EventProviderAPI_GetCustomEventsRPC_Handler,
		},
		{
			MethodName: "GetABCIBlockEvents",
			Handler:    _EventProviderAPI_GetABCIBlockEvents_Handler,
		},
		{
			MethodName: "GetABCIBlockEventsAtHeight",
			Handler:    _EventProviderAPI_GetABCIBlockEventsAtHeight_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamBlockEvents",
			Handler:       _EventProviderAPI_StreamBlockEvents_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "goadesign_goagen_event_provider_api.proto",
}

EventProviderAPI_ServiceDesc is the grpc.ServiceDesc for EventProviderAPI service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_goadesign_goagen_event_provider_api_proto protoreflect.FileDescriptor

Functions

func RegisterEventProviderAPIServer 

func RegisterEventProviderAPIServer(s grpc.ServiceRegistrar, srv EventProviderAPIServer)

Types

type ABCIAttribute 

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
}

func (*ABCIAttribute) Descriptor deprecated 

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

Deprecated: Use ABCIAttribute.ProtoReflect.Descriptor instead.

func (*ABCIAttribute) GetKey 

func (x *ABCIAttribute) GetKey() string

func (*ABCIAttribute) GetValue 

func (x *ABCIAttribute) GetValue() string

func (*ABCIAttribute) ProtoMessage 

func (*ABCIAttribute) ProtoMessage()

func (*ABCIAttribute) ProtoReflect 

func (x *ABCIAttribute) ProtoReflect() protoreflect.Message

func (*ABCIAttribute) Reset 

func (x *ABCIAttribute) Reset()

func (*ABCIAttribute) String 

func (x *ABCIAttribute) String() string

type ABCIEvent 

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
}

func (*ABCIEvent) Descriptor deprecated 

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

Deprecated: Use ABCIEvent.ProtoReflect.Descriptor instead.

func (*ABCIEvent) GetAttributes 

func (x *ABCIEvent) GetAttributes() []*ABCIAttribute

func (*ABCIEvent) GetType 

func (x *ABCIEvent) GetType() string

func (*ABCIEvent) ProtoMessage 

func (*ABCIEvent) ProtoMessage()

func (*ABCIEvent) ProtoReflect 

func (x *ABCIEvent) ProtoReflect() protoreflect.Message

func (*ABCIEvent) Reset 

func (x *ABCIEvent) Reset()

func (*ABCIEvent) String 

func (x *ABCIEvent) String() string

type ABCIResponseDeliverTx 

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
}

func (*ABCIResponseDeliverTx) Descriptor deprecated 

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

Deprecated: Use ABCIResponseDeliverTx.ProtoReflect.Descriptor instead.

func (*ABCIResponseDeliverTx) GetCode 

func (x *ABCIResponseDeliverTx) GetCode() int32

func (*ABCIResponseDeliverTx) GetCodespace 

func (x *ABCIResponseDeliverTx) GetCodespace() string

func (*ABCIResponseDeliverTx) GetEvents 

func (x *ABCIResponseDeliverTx) GetEvents() []*ABCIEvent

func (*ABCIResponseDeliverTx) GetGasUsed 

func (x *ABCIResponseDeliverTx) GetGasUsed() int64

func (*ABCIResponseDeliverTx) GetGasWanted 

func (x *ABCIResponseDeliverTx) GetGasWanted() int64

func (*ABCIResponseDeliverTx) GetInfo 

func (x *ABCIResponseDeliverTx) GetInfo() string

func (*ABCIResponseDeliverTx) GetLog 

func (x *ABCIResponseDeliverTx) GetLog() string

func (*ABCIResponseDeliverTx) GetTxHash 

func (x *ABCIResponseDeliverTx) GetTxHash() []byte

func (*ABCIResponseDeliverTx) ProtoMessage 

func (*ABCIResponseDeliverTx) ProtoMessage()

func (*ABCIResponseDeliverTx) ProtoReflect 

func (x *ABCIResponseDeliverTx) ProtoReflect() protoreflect.Message

func (*ABCIResponseDeliverTx) Reset 

func (x *ABCIResponseDeliverTx) Reset()

func (*ABCIResponseDeliverTx) String 

func (x *ABCIResponseDeliverTx) String() string

type Block 

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"`
	// contains filtered or unexported fields
}

func (*Block) Descriptor deprecated 

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

Deprecated: Use Block.ProtoReflect.Descriptor instead.

func (*Block) GetEvents 

func (x *Block) GetEvents() []*BlockEvent

func (*Block) GetHeight 

func (x *Block) GetHeight() int64

func (*Block) GetInSync 

func (x *Block) GetInSync() bool

func (*Block) GetVersion 

func (x *Block) GetVersion() string

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) ProtoReflect 

func (x *Block) ProtoReflect() protoreflect.Message

func (*Block) Reset 

func (x *Block) Reset()

func (*Block) String 

func (x *Block) String() string

type BlockEvent 

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
}

func (*BlockEvent) Descriptor deprecated 

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

Deprecated: Use BlockEvent.ProtoReflect.Descriptor instead.

func (*BlockEvent) GetMode 

func (x *BlockEvent) GetMode() string

func (*BlockEvent) GetTxHash 

func (x *BlockEvent) GetTxHash() []byte

func (*BlockEvent) GetTypeUrl 

func (x *BlockEvent) GetTypeUrl() string

func (*BlockEvent) GetValue 

func (x *BlockEvent) GetValue() []byte

func (*BlockEvent) ProtoMessage 

func (*BlockEvent) ProtoMessage()

func (*BlockEvent) ProtoReflect 

func (x *BlockEvent) ProtoReflect() protoreflect.Message

func (*BlockEvent) Reset 

func (x *BlockEvent) Reset()

func (*BlockEvent) String 

func (x *BlockEvent) String() string

type BlockEventsRPC 

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
}

Processed block events for backend processor to consume

func (*BlockEventsRPC) Descriptor deprecated 

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

Deprecated: Use BlockEventsRPC.ProtoReflect.Descriptor instead.

func (*BlockEventsRPC) GetEvents 

func (x *BlockEventsRPC) GetEvents() [][]byte

func (*BlockEventsRPC) GetTxHashes 

func (x *BlockEventsRPC) GetTxHashes() map[int32][]byte

func (*BlockEventsRPC) GetTypes 

func (x *BlockEventsRPC) GetTypes() []string

func (*BlockEventsRPC) ProtoMessage 

func (*BlockEventsRPC) ProtoMessage()

func (*BlockEventsRPC) ProtoReflect 

func (x *BlockEventsRPC) ProtoReflect() protoreflect.Message

func (*BlockEventsRPC) Reset 

func (x *BlockEventsRPC) Reset()

func (*BlockEventsRPC) String 

func (x *BlockEventsRPC) String() string

type EventProviderAPIClient 

type EventProviderAPIClient interface {
	// Get latest block from event provider
	GetLatestHeight(ctx context.Context, in *GetLatestHeightRequest, opts ...grpc.CallOption) (*GetLatestHeightResponse, 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)
}

EventProviderAPIClient is the client API for EventProviderAPI service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewEventProviderAPIClient 

func NewEventProviderAPIClient(cc grpc.ClientConnInterface) EventProviderAPIClient

type EventProviderAPIServer 

type EventProviderAPIServer interface {
	// Get latest block from event provider
	GetLatestHeight(context.Context, *GetLatestHeightRequest) (*GetLatestHeightResponse, 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)
	// contains filtered or unexported methods
}

EventProviderAPIServer is the server API for EventProviderAPI service. All implementations must embed UnimplementedEventProviderAPIServer for forward compatibility

type EventProviderAPI_StreamBlockEventsClient 

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

type EventProviderAPI_StreamBlockEventsServer 

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

type GetABCIBlockEventsAtHeightRequest 

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

func (*GetABCIBlockEventsAtHeightRequest) Descriptor deprecated 

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

Deprecated: Use GetABCIBlockEventsAtHeightRequest.ProtoReflect.Descriptor instead.

func (*GetABCIBlockEventsAtHeightRequest) GetHeight 

func (x *GetABCIBlockEventsAtHeightRequest) GetHeight() int32

func (*GetABCIBlockEventsAtHeightRequest) ProtoMessage 

func (*GetABCIBlockEventsAtHeightRequest) ProtoMessage()

func (*GetABCIBlockEventsAtHeightRequest) ProtoReflect 

func (x *GetABCIBlockEventsAtHeightRequest) ProtoReflect() protoreflect.Message

func (*GetABCIBlockEventsAtHeightRequest) Reset 

func (x *GetABCIBlockEventsAtHeightRequest) Reset()

func (*GetABCIBlockEventsAtHeightRequest) String 

func (x *GetABCIBlockEventsAtHeightRequest) String() string

type GetABCIBlockEventsAtHeightResponse 

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
}

func (*GetABCIBlockEventsAtHeightResponse) Descriptor deprecated 

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

Deprecated: Use GetABCIBlockEventsAtHeightResponse.ProtoReflect.Descriptor instead.

func (*GetABCIBlockEventsAtHeightResponse) GetE 

func (x *GetABCIBlockEventsAtHeightResponse) GetE() string

func (*GetABCIBlockEventsAtHeightResponse) GetRawBlock 

func (x *GetABCIBlockEventsAtHeightResponse) GetRawBlock() *RawBlock

func (*GetABCIBlockEventsAtHeightResponse) GetS 

func (x *GetABCIBlockEventsAtHeightResponse) GetS() string

func (*GetABCIBlockEventsAtHeightResponse) GetV 

func (x *GetABCIBlockEventsAtHeightResponse) GetV() string

func (*GetABCIBlockEventsAtHeightResponse) ProtoMessage 

func (*GetABCIBlockEventsAtHeightResponse) ProtoMessage()

func (*GetABCIBlockEventsAtHeightResponse) ProtoReflect 

func (x *GetABCIBlockEventsAtHeightResponse) ProtoReflect() protoreflect.Message

func (*GetABCIBlockEventsAtHeightResponse) Reset 

func (x *GetABCIBlockEventsAtHeightResponse) Reset()

func (*GetABCIBlockEventsAtHeightResponse) String 

func (x *GetABCIBlockEventsAtHeightResponse) String() string

type GetABCIBlockEventsRequest 

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
}

func (*GetABCIBlockEventsRequest) Descriptor deprecated 

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

Deprecated: Use GetABCIBlockEventsRequest.ProtoReflect.Descriptor instead.

func (*GetABCIBlockEventsRequest) GetEventTypes 

func (x *GetABCIBlockEventsRequest) GetEventTypes() []string

func (*GetABCIBlockEventsRequest) GetHeight 

func (x *GetABCIBlockEventsRequest) GetHeight() int32

func (*GetABCIBlockEventsRequest) ProtoMessage 

func (*GetABCIBlockEventsRequest) ProtoMessage()

func (*GetABCIBlockEventsRequest) ProtoReflect 

func (x *GetABCIBlockEventsRequest) ProtoReflect() protoreflect.Message

func (*GetABCIBlockEventsRequest) Reset 

func (x *GetABCIBlockEventsRequest) Reset()

func (*GetABCIBlockEventsRequest) String 

func (x *GetABCIBlockEventsRequest) String() string

type GetABCIBlockEventsResponse 

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
}

func (*GetABCIBlockEventsResponse) Descriptor deprecated 

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

Deprecated: Use GetABCIBlockEventsResponse.ProtoReflect.Descriptor instead.

func (*GetABCIBlockEventsResponse) GetE 

func (x *GetABCIBlockEventsResponse) GetE() string

func (*GetABCIBlockEventsResponse) GetRawBlock 

func (x *GetABCIBlockEventsResponse) GetRawBlock() *RawBlock

func (*GetABCIBlockEventsResponse) GetS 

func (x *GetABCIBlockEventsResponse) GetS() string

func (*GetABCIBlockEventsResponse) GetV 

func (x *GetABCIBlockEventsResponse) GetV() string

func (*GetABCIBlockEventsResponse) ProtoMessage 

func (*GetABCIBlockEventsResponse) ProtoMessage()

func (*GetABCIBlockEventsResponse) ProtoReflect 

func (x *GetABCIBlockEventsResponse) ProtoReflect() protoreflect.Message

func (*GetABCIBlockEventsResponse) Reset 

func (x *GetABCIBlockEventsResponse) Reset()

func (*GetABCIBlockEventsResponse) String 

func (x *GetABCIBlockEventsResponse) String() string

type GetBlockEventsRPCRequest 

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
}

func (*GetBlockEventsRPCRequest) Descriptor deprecated 

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

Deprecated: Use GetBlockEventsRPCRequest.ProtoReflect.Descriptor instead.

func (*GetBlockEventsRPCRequest) GetBackend 

func (x *GetBlockEventsRPCRequest) GetBackend() string

func (*GetBlockEventsRPCRequest) GetHeight 

func (x *GetBlockEventsRPCRequest) GetHeight() int32

func (*GetBlockEventsRPCRequest) GetHumanReadable 

func (x *GetBlockEventsRPCRequest) GetHumanReadable() bool

func (*GetBlockEventsRPCRequest) ProtoMessage 

func (*GetBlockEventsRPCRequest) ProtoMessage()

func (*GetBlockEventsRPCRequest) ProtoReflect 

func (x *GetBlockEventsRPCRequest) ProtoReflect() protoreflect.Message

func (*GetBlockEventsRPCRequest) Reset 

func (x *GetBlockEventsRPCRequest) Reset()

func (*GetBlockEventsRPCRequest) String 

func (x *GetBlockEventsRPCRequest) String() string

type GetBlockEventsRPCResponse 

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"`
	// contains filtered or unexported fields
}

func (*GetBlockEventsRPCResponse) Descriptor deprecated 

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

Deprecated: Use GetBlockEventsRPCResponse.ProtoReflect.Descriptor instead.

func (*GetBlockEventsRPCResponse) GetData 

func (x *GetBlockEventsRPCResponse) GetData() *BlockEventsRPC

func (*GetBlockEventsRPCResponse) GetE 

func (x *GetBlockEventsRPCResponse) GetE() string

func (*GetBlockEventsRPCResponse) GetS 

func (x *GetBlockEventsRPCResponse) GetS() string

func (*GetBlockEventsRPCResponse) GetV 

func (x *GetBlockEventsRPCResponse) GetV() string

func (*GetBlockEventsRPCResponse) ProtoMessage 

func (*GetBlockEventsRPCResponse) ProtoMessage()

func (*GetBlockEventsRPCResponse) ProtoReflect 

func (x *GetBlockEventsRPCResponse) ProtoReflect() protoreflect.Message

func (*GetBlockEventsRPCResponse) Reset 

func (x *GetBlockEventsRPCResponse) Reset()

func (*GetBlockEventsRPCResponse) String 

func (x *GetBlockEventsRPCResponse) String() string

type GetCustomEventsRPCRequest 

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
}

func (*GetCustomEventsRPCRequest) Descriptor deprecated 

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

Deprecated: Use GetCustomEventsRPCRequest.ProtoReflect.Descriptor instead.

func (*GetCustomEventsRPCRequest) GetBackend 

func (x *GetCustomEventsRPCRequest) GetBackend() string

func (*GetCustomEventsRPCRequest) GetEvents 

func (x *GetCustomEventsRPCRequest) GetEvents() string

func (*GetCustomEventsRPCRequest) GetHeight 

func (x *GetCustomEventsRPCRequest) GetHeight() int32

func (*GetCustomEventsRPCRequest) ProtoMessage 

func (*GetCustomEventsRPCRequest) ProtoMessage()

func (*GetCustomEventsRPCRequest) ProtoReflect 

func (x *GetCustomEventsRPCRequest) ProtoReflect() protoreflect.Message

func (*GetCustomEventsRPCRequest) Reset 

func (x *GetCustomEventsRPCRequest) Reset()

func (*GetCustomEventsRPCRequest) String 

func (x *GetCustomEventsRPCRequest) String() string

type GetCustomEventsRPCResponse 

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"`
	// contains filtered or unexported fields
}

func (*GetCustomEventsRPCResponse) Descriptor deprecated 

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

Deprecated: Use GetCustomEventsRPCResponse.ProtoReflect.Descriptor instead.

func (*GetCustomEventsRPCResponse) GetData 

func (x *GetCustomEventsRPCResponse) GetData() *BlockEventsRPC

func (*GetCustomEventsRPCResponse) GetE 

func (x *GetCustomEventsRPCResponse) GetE() string

func (*GetCustomEventsRPCResponse) GetS 

func (x *GetCustomEventsRPCResponse) GetS() string

func (*GetCustomEventsRPCResponse) GetV 

func (x *GetCustomEventsRPCResponse) GetV() string

func (*GetCustomEventsRPCResponse) ProtoMessage 

func (*GetCustomEventsRPCResponse) ProtoMessage()

func (*GetCustomEventsRPCResponse) ProtoReflect 

func (x *GetCustomEventsRPCResponse) ProtoReflect() protoreflect.Message

func (*GetCustomEventsRPCResponse) Reset 

func (x *GetCustomEventsRPCResponse) Reset()

func (*GetCustomEventsRPCResponse) String 

func (x *GetCustomEventsRPCResponse) String() string

type GetLatestHeightRequest 

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

func (*GetLatestHeightRequest) Descriptor deprecated 

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

Deprecated: Use GetLatestHeightRequest.ProtoReflect.Descriptor instead.

func (*GetLatestHeightRequest) ProtoMessage 

func (*GetLatestHeightRequest) ProtoMessage()

func (*GetLatestHeightRequest) ProtoReflect 

func (x *GetLatestHeightRequest) ProtoReflect() protoreflect.Message

func (*GetLatestHeightRequest) Reset 

func (x *GetLatestHeightRequest) Reset()

func (*GetLatestHeightRequest) String 

func (x *GetLatestHeightRequest) String() string

type GetLatestHeightResponse 

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
}

func (*GetLatestHeightResponse) Descriptor deprecated 

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

Deprecated: Use GetLatestHeightResponse.ProtoReflect.Descriptor instead.

func (*GetLatestHeightResponse) GetData 

func (x *GetLatestHeightResponse) GetData() *LatestBlockHeight

func (*GetLatestHeightResponse) GetE 

func (x *GetLatestHeightResponse) GetE() string

func (*GetLatestHeightResponse) GetS 

func (x *GetLatestHeightResponse) GetS() string

func (*GetLatestHeightResponse) GetV 

func (x *GetLatestHeightResponse) GetV() string

func (*GetLatestHeightResponse) ProtoMessage 

func (*GetLatestHeightResponse) ProtoMessage()

func (*GetLatestHeightResponse) ProtoReflect 

func (x *GetLatestHeightResponse) ProtoReflect() protoreflect.Message

func (*GetLatestHeightResponse) Reset 

func (x *GetLatestHeightResponse) Reset()

func (*GetLatestHeightResponse) String 

func (x *GetLatestHeightResponse) String() string

type LatestBlockHeight 

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
}

Latest block height from event provider db

func (*LatestBlockHeight) Descriptor deprecated 

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

Deprecated: Use LatestBlockHeight.ProtoReflect.Descriptor instead.

func (*LatestBlockHeight) GetHeight 

func (x *LatestBlockHeight) GetHeight() uint64

func (*LatestBlockHeight) GetTime 

func (x *LatestBlockHeight) GetTime() int64

func (*LatestBlockHeight) ProtoMessage 

func (*LatestBlockHeight) ProtoMessage()

func (*LatestBlockHeight) ProtoReflect 

func (x *LatestBlockHeight) ProtoReflect() protoreflect.Message

func (*LatestBlockHeight) Reset 

func (x *LatestBlockHeight) Reset()

func (*LatestBlockHeight) String 

func (x *LatestBlockHeight) String() string

type RawBlock 

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
}

func (*RawBlock) Descriptor deprecated 

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

Deprecated: Use RawBlock.ProtoReflect.Descriptor instead.

func (*RawBlock) GetBeginBlockEvents 

func (x *RawBlock) GetBeginBlockEvents() []*ABCIEvent

func (*RawBlock) GetBlockTime 

func (x *RawBlock) GetBlockTime() string

func (*RawBlock) GetBlockTimestamp 

func (x *RawBlock) GetBlockTimestamp() int64

func (*RawBlock) GetEndBlockEvents 

func (x *RawBlock) GetEndBlockEvents() []*ABCIEvent

func (*RawBlock) GetHeight 

func (x *RawBlock) GetHeight() int64

func (*RawBlock) GetTxsResults 

func (x *RawBlock) GetTxsResults() []*ABCIResponseDeliverTx

func (*RawBlock) ProtoMessage 

func (*RawBlock) ProtoMessage()

func (*RawBlock) ProtoReflect 

func (x *RawBlock) ProtoReflect() protoreflect.Message

func (*RawBlock) Reset 

func (x *RawBlock) Reset()

func (*RawBlock) String 

func (x *RawBlock) String() string

type StreamBlockEventsRequest 

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"`
	// contains filtered or unexported fields
}

func (*StreamBlockEventsRequest) Descriptor deprecated 

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

Deprecated: Use StreamBlockEventsRequest.ProtoReflect.Descriptor instead.

func (*StreamBlockEventsRequest) GetBackend 

func (x *StreamBlockEventsRequest) GetBackend() string

func (*StreamBlockEventsRequest) GetHeight 

func (x *StreamBlockEventsRequest) GetHeight() int32

func (*StreamBlockEventsRequest) ProtoMessage 

func (*StreamBlockEventsRequest) ProtoMessage()

func (*StreamBlockEventsRequest) ProtoReflect 

func (x *StreamBlockEventsRequest) ProtoReflect() protoreflect.Message

func (*StreamBlockEventsRequest) Reset 

func (x *StreamBlockEventsRequest) Reset()

func (*StreamBlockEventsRequest) String 

func (x *StreamBlockEventsRequest) String() string

type StreamBlockEventsResponse 

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

func (*StreamBlockEventsResponse) Descriptor deprecated 

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

Deprecated: Use StreamBlockEventsResponse.ProtoReflect.Descriptor instead.

func (*StreamBlockEventsResponse) GetBlocks 

func (x *StreamBlockEventsResponse) GetBlocks() []*Block

func (*StreamBlockEventsResponse) ProtoMessage 

func (*StreamBlockEventsResponse) ProtoMessage()

func (*StreamBlockEventsResponse) ProtoReflect 

func (x *StreamBlockEventsResponse) ProtoReflect() protoreflect.Message

func (*StreamBlockEventsResponse) Reset 

func (x *StreamBlockEventsResponse) Reset()

func (*StreamBlockEventsResponse) String 

func (x *StreamBlockEventsResponse) String() string

type UnimplementedEventProviderAPIServer 

type UnimplementedEventProviderAPIServer struct {
}

UnimplementedEventProviderAPIServer must be embedded to have forward compatible implementations.

func (UnimplementedEventProviderAPIServer) GetABCIBlockEvents 

func (UnimplementedEventProviderAPIServer) GetABCIBlockEvents(context.Context, *GetABCIBlockEventsRequest) (*GetABCIBlockEventsResponse, error)

func (UnimplementedEventProviderAPIServer) GetABCIBlockEventsAtHeight 

func (UnimplementedEventProviderAPIServer) GetABCIBlockEventsAtHeight(context.Context, *GetABCIBlockEventsAtHeightRequest) (*GetABCIBlockEventsAtHeightResponse, error)

func (UnimplementedEventProviderAPIServer) GetBlockEventsRPC 

func (UnimplementedEventProviderAPIServer) GetBlockEventsRPC(context.Context, *GetBlockEventsRPCRequest) (*GetBlockEventsRPCResponse, error)

func (UnimplementedEventProviderAPIServer) GetCustomEventsRPC 

func (UnimplementedEventProviderAPIServer) GetCustomEventsRPC(context.Context, *GetCustomEventsRPCRequest) (*GetCustomEventsRPCResponse, error)

func (UnimplementedEventProviderAPIServer) GetLatestHeight 

func (UnimplementedEventProviderAPIServer) GetLatestHeight(context.Context, *GetLatestHeightRequest) (*GetLatestHeightResponse, error)

func (UnimplementedEventProviderAPIServer) StreamBlockEvents 

func (UnimplementedEventProviderAPIServer) StreamBlockEvents(*StreamBlockEventsRequest, EventProviderAPI_StreamBlockEventsServer) error

type UnsafeEventProviderAPIServer 

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

UnsafeEventProviderAPIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventProviderAPIServer will result in compilation errors.

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.