streamingv1

package
v0.7.6 Latest Latest
Warning

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

 Go to latest Published: Jan 31, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Index

Constants

View Source 
const (
	ListenerService_ListenDeliverBlock_FullMethodName = "/cosmos.streaming.v1.ListenerService/ListenDeliverBlock"
	ListenerService_ListenStateChanges_FullMethodName = "/cosmos.streaming.v1.ListenerService/ListenStateChanges"
)

Variables

View Source 
var File_cosmos_streaming_v1_grpc_proto protoreflect.FileDescriptor
View Source 
var ListenerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cosmos.streaming.v1.ListenerService",
	HandlerType: (*ListenerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListenDeliverBlock",
			Handler:    _ListenerService_ListenDeliverBlock_Handler,
		},
		{
			MethodName: "ListenStateChanges",
			Handler:    _ListenerService_ListenStateChanges_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cosmos/streaming/v1/grpc.proto",
}

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

Functions

func RegisterListenerServiceServer 

func RegisterListenerServiceServer(s grpc.ServiceRegistrar, srv ListenerServiceServer)

Types

type Event 

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

Event is a single event, associated with a transaction.

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetAttributes 

func (x *Event) GetAttributes() []*EventAttribute

func (*Event) GetType_ 

func (x *Event) GetType_() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type EventAttribute 

type EventAttribute 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
}

EventAttribute is a single key-value pair, associated with an event.

func (*EventAttribute) Descriptor deprecated 

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

Deprecated: Use EventAttribute.ProtoReflect.Descriptor instead.

func (*EventAttribute) GetKey 

func (x *EventAttribute) GetKey() string

func (*EventAttribute) GetValue 

func (x *EventAttribute) GetValue() string

func (*EventAttribute) ProtoMessage 

func (*EventAttribute) ProtoMessage()

func (*EventAttribute) ProtoReflect 

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

func (*EventAttribute) Reset 

func (x *EventAttribute) Reset()

func (*EventAttribute) String 

func (x *EventAttribute) String() string

type ExecTxResult 

type ExecTxResult struct {
	Code      uint32   `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Data      []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Log       string   `protobuf:"bytes,3,opt,name=log,proto3" json:"log,omitempty"`
	Info      string   `protobuf:"bytes,4,opt,name=info,proto3" json:"info,omitempty"`
	GasWanted int64    `protobuf:"varint,5,opt,name=gas_wanted,json=gasWanted,proto3" json:"gas_wanted,omitempty"`
	GasUsed   int64    `protobuf:"varint,6,opt,name=gas_used,json=gasUsed,proto3" json:"gas_used,omitempty"`
	Events    []*Event `protobuf:"bytes,7,rep,name=events,proto3" json:"events,omitempty"`
	Codespace string   `protobuf:"bytes,8,opt,name=codespace,proto3" json:"codespace,omitempty"`
	// contains filtered or unexported fields
}

ExecTxResult contains results of executing one individual transaction.

func (*ExecTxResult) Descriptor deprecated 

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

Deprecated: Use ExecTxResult.ProtoReflect.Descriptor instead.

func (*ExecTxResult) GetCode 

func (x *ExecTxResult) GetCode() uint32

func (*ExecTxResult) GetCodespace 

func (x *ExecTxResult) GetCodespace() string

func (*ExecTxResult) GetData 

func (x *ExecTxResult) GetData() []byte

func (*ExecTxResult) GetEvents 

func (x *ExecTxResult) GetEvents() []*Event

func (*ExecTxResult) GetGasUsed 

func (x *ExecTxResult) GetGasUsed() int64

func (*ExecTxResult) GetGasWanted 

func (x *ExecTxResult) GetGasWanted() int64

func (*ExecTxResult) GetInfo 

func (x *ExecTxResult) GetInfo() string

func (*ExecTxResult) GetLog 

func (x *ExecTxResult) GetLog() string

func (*ExecTxResult) ProtoMessage 

func (*ExecTxResult) ProtoMessage()

func (*ExecTxResult) ProtoReflect 

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

func (*ExecTxResult) Reset 

func (x *ExecTxResult) Reset()

func (*ExecTxResult) String 

func (x *ExecTxResult) String() string

type ListenDeliverBlockRequest 

type ListenDeliverBlockRequest struct {
	BlockHeight int64           `protobuf:"varint,1,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	Txs         [][]byte        `protobuf:"bytes,2,rep,name=txs,proto3" json:"txs,omitempty"`
	Events      []*Event        `protobuf:"bytes,3,rep,name=events,proto3" json:"events,omitempty"`
	TxResults   []*ExecTxResult `protobuf:"bytes,4,rep,name=tx_results,json=txResults,proto3" json:"tx_results,omitempty"`
	// contains filtered or unexported fields
}

ListenDeliverBlockRequest is the request type for the ListenDeliverBlock RPC method

func (*ListenDeliverBlockRequest) Descriptor deprecated 

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

Deprecated: Use ListenDeliverBlockRequest.ProtoReflect.Descriptor instead.

func (*ListenDeliverBlockRequest) GetBlockHeight 

func (x *ListenDeliverBlockRequest) GetBlockHeight() int64

func (*ListenDeliverBlockRequest) GetEvents 

func (x *ListenDeliverBlockRequest) GetEvents() []*Event

func (*ListenDeliverBlockRequest) GetTxResults 

func (x *ListenDeliverBlockRequest) GetTxResults() []*ExecTxResult

func (*ListenDeliverBlockRequest) GetTxs 

func (x *ListenDeliverBlockRequest) GetTxs() [][]byte

func (*ListenDeliverBlockRequest) ProtoMessage 

func (*ListenDeliverBlockRequest) ProtoMessage()

func (*ListenDeliverBlockRequest) ProtoReflect 

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

func (*ListenDeliverBlockRequest) Reset 

func (x *ListenDeliverBlockRequest) Reset()

func (*ListenDeliverBlockRequest) String 

func (x *ListenDeliverBlockRequest) String() string

type ListenDeliverBlockResponse 

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

ListenDeliverBlockResponse is the response type for the ListenDeliverBlock RPC method

func (*ListenDeliverBlockResponse) Descriptor deprecated 

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

Deprecated: Use ListenDeliverBlockResponse.ProtoReflect.Descriptor instead.

func (*ListenDeliverBlockResponse) ProtoMessage 

func (*ListenDeliverBlockResponse) ProtoMessage()

func (*ListenDeliverBlockResponse) ProtoReflect 

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

func (*ListenDeliverBlockResponse) Reset 

func (x *ListenDeliverBlockResponse) Reset()

func (*ListenDeliverBlockResponse) String 

func (x *ListenDeliverBlockResponse) String() string

type ListenStateChangesRequest 

type ListenStateChangesRequest struct {
	BlockHeight int64          `protobuf:"varint,1,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	ChangeSet   []*StoreKVPair `protobuf:"bytes,2,rep,name=change_set,json=changeSet,proto3" json:"change_set,omitempty"`
	AppHash     []byte         `protobuf:"bytes,3,opt,name=app_hash,json=appHash,proto3" json:"app_hash,omitempty"`
	// contains filtered or unexported fields
}

ListenStateChangesRequest is the request type for the ListenStateChanges RPC method

func (*ListenStateChangesRequest) Descriptor deprecated 

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

Deprecated: Use ListenStateChangesRequest.ProtoReflect.Descriptor instead.

func (*ListenStateChangesRequest) GetAppHash 

func (x *ListenStateChangesRequest) GetAppHash() []byte

func (*ListenStateChangesRequest) GetBlockHeight 

func (x *ListenStateChangesRequest) GetBlockHeight() int64

func (*ListenStateChangesRequest) GetChangeSet 

func (x *ListenStateChangesRequest) GetChangeSet() []*StoreKVPair

func (*ListenStateChangesRequest) ProtoMessage 

func (*ListenStateChangesRequest) ProtoMessage()

func (*ListenStateChangesRequest) ProtoReflect 

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

func (*ListenStateChangesRequest) Reset 

func (x *ListenStateChangesRequest) Reset()

func (*ListenStateChangesRequest) String 

func (x *ListenStateChangesRequest) String() string

type ListenStateChangesResponse 

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

ListenStateChangesResponse is the response type for the ListenStateChanges RPC method

func (*ListenStateChangesResponse) Descriptor deprecated 

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

Deprecated: Use ListenStateChangesResponse.ProtoReflect.Descriptor instead.

func (*ListenStateChangesResponse) ProtoMessage 

func (*ListenStateChangesResponse) ProtoMessage()

func (*ListenStateChangesResponse) ProtoReflect 

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

func (*ListenStateChangesResponse) Reset 

func (x *ListenStateChangesResponse) Reset()

func (*ListenStateChangesResponse) String 

func (x *ListenStateChangesResponse) String() string

type ListenerServiceClient 

type ListenerServiceClient interface {
	// ListenDeliverBlock is the corresponding endpoint for Listener.ListenDeliverBlock
	ListenDeliverBlock(ctx context.Context, in *ListenDeliverBlockRequest, opts ...grpc.CallOption) (*ListenDeliverBlockResponse, error)
	// ListenStateChanges is the corresponding endpoint for Listener.ListenStateChanges
	ListenStateChanges(ctx context.Context, in *ListenStateChangesRequest, opts ...grpc.CallOption) (*ListenStateChangesResponse, error)
}

ListenerServiceClient is the client API for ListenerService 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.

ListenerService is the service for the Listener interface

func NewListenerServiceClient 

func NewListenerServiceClient(cc grpc.ClientConnInterface) ListenerServiceClient

type ListenerServiceServer 

type ListenerServiceServer interface {
	// ListenDeliverBlock is the corresponding endpoint for Listener.ListenDeliverBlock
	ListenDeliverBlock(context.Context, *ListenDeliverBlockRequest) (*ListenDeliverBlockResponse, error)
	// ListenStateChanges is the corresponding endpoint for Listener.ListenStateChanges
	ListenStateChanges(context.Context, *ListenStateChangesRequest) (*ListenStateChangesResponse, error)
	// contains filtered or unexported methods
}

ListenerServiceServer is the server API for ListenerService service. All implementations must embed UnimplementedListenerServiceServer for forward compatibility.

ListenerService is the service for the Listener interface

type StoreKVPair 

type StoreKVPair struct {

	// address defines the address of the account the state changes are coming from.
	// In case of modules you can expect a stringified
	Address []byte `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// key defines the key of the address that changed.
	Key []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// value defines the value that changed, empty in case of removal.
	Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// delete defines if the key was removed.
	Delete bool `protobuf:"varint,4,opt,name=delete,proto3" json:"delete,omitempty"` // true indicates a delete operation, false indicates a set operation
	// contains filtered or unexported fields
}

StoreKVPair is a single key-value pair, associated with a store.

func (*StoreKVPair) Descriptor deprecated 

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

Deprecated: Use StoreKVPair.ProtoReflect.Descriptor instead.

func (*StoreKVPair) GetAddress 

func (x *StoreKVPair) GetAddress() []byte

func (*StoreKVPair) GetDelete 

func (x *StoreKVPair) GetDelete() bool

func (*StoreKVPair) GetKey 

func (x *StoreKVPair) GetKey() []byte

func (*StoreKVPair) GetValue 

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

func (*StoreKVPair) ProtoMessage 

func (*StoreKVPair) ProtoMessage()

func (*StoreKVPair) ProtoReflect 

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

func (*StoreKVPair) Reset 

func (x *StoreKVPair) Reset()

func (*StoreKVPair) String 

func (x *StoreKVPair) String() string

type UnimplementedListenerServiceServer 

type UnimplementedListenerServiceServer struct{}

UnimplementedListenerServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedListenerServiceServer) ListenDeliverBlock 

func (UnimplementedListenerServiceServer) ListenDeliverBlock(context.Context, *ListenDeliverBlockRequest) (*ListenDeliverBlockResponse, error)

func (UnimplementedListenerServiceServer) ListenStateChanges 

func (UnimplementedListenerServiceServer) ListenStateChanges(context.Context, *ListenStateChangesRequest) (*ListenStateChangesResponse, error)

type UnsafeListenerServiceServer 

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

UnsafeListenerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ListenerServiceServer 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.