Documentation ¶
Overview ¶
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Index ¶
- Constants
- Variables
- func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)
- type EpochInfo
- func (*EpochInfo) Descriptor() ([]byte, []int)deprecated
- func (x *EpochInfo) GetCurrentEpoch() int64
- func (x *EpochInfo) GetCurrentEpochStartHeight() int64
- func (x *EpochInfo) GetCurrentEpochStartTime() *timestamppb.Timestamp
- func (x *EpochInfo) GetDuration() *durationpb.Duration
- func (x *EpochInfo) GetEpochCountingStarted() bool
- func (x *EpochInfo) GetIdentifier() string
- func (x *EpochInfo) GetStartTime() *timestamppb.Timestamp
- func (*EpochInfo) ProtoMessage()
- func (x *EpochInfo) ProtoReflect() protoreflect.Message
- func (x *EpochInfo) Reset()
- func (x *EpochInfo) String() string
- type GenesisState
- type QueryClient
- type QueryCurrentEpochRequest
- func (*QueryCurrentEpochRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryCurrentEpochRequest) GetIdentifier() string
- func (*QueryCurrentEpochRequest) ProtoMessage()
- func (x *QueryCurrentEpochRequest) ProtoReflect() protoreflect.Message
- func (x *QueryCurrentEpochRequest) Reset()
- func (x *QueryCurrentEpochRequest) String() string
- type QueryCurrentEpochResponse
- func (*QueryCurrentEpochResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryCurrentEpochResponse) GetCurrentEpoch() int64
- func (*QueryCurrentEpochResponse) ProtoMessage()
- func (x *QueryCurrentEpochResponse) ProtoReflect() protoreflect.Message
- func (x *QueryCurrentEpochResponse) Reset()
- func (x *QueryCurrentEpochResponse) String() string
- type QueryEpochsInfoRequest
- func (*QueryEpochsInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryEpochsInfoRequest) GetPagination() *v1beta1.PageRequest
- func (*QueryEpochsInfoRequest) ProtoMessage()
- func (x *QueryEpochsInfoRequest) ProtoReflect() protoreflect.Message
- func (x *QueryEpochsInfoRequest) Reset()
- func (x *QueryEpochsInfoRequest) String() string
- type QueryEpochsInfoResponse
- func (*QueryEpochsInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryEpochsInfoResponse) GetEpochs() []*EpochInfo
- func (x *QueryEpochsInfoResponse) GetPagination() *v1beta1.PageResponse
- func (*QueryEpochsInfoResponse) ProtoMessage()
- func (x *QueryEpochsInfoResponse) ProtoReflect() protoreflect.Message
- func (x *QueryEpochsInfoResponse) Reset()
- func (x *QueryEpochsInfoResponse) String() string
- type QueryServer
- type UnimplementedQueryServer
- type UnsafeQueryServer
Constants ¶
const ( Query_EpochInfos_FullMethodName = "/canto.epochs.v1.Query/EpochInfos" Query_CurrentEpoch_FullMethodName = "/canto.epochs.v1.Query/CurrentEpoch" )
Variables ¶
var File_canto_epochs_v1_genesis_proto protoreflect.FileDescriptor
var File_canto_epochs_v1_query_proto protoreflect.FileDescriptor
var Query_ServiceDesc = grpc.ServiceDesc{ ServiceName: "canto.epochs.v1.Query", HandlerType: (*QueryServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "EpochInfos", Handler: _Query_EpochInfos_Handler, }, { MethodName: "CurrentEpoch", Handler: _Query_CurrentEpoch_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "canto/epochs/v1/query.proto", }
Query_ServiceDesc is the grpc.ServiceDesc for Query service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)
Types ¶
type EpochInfo ¶
type EpochInfo struct { Identifier string `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"` StartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` Duration *durationpb.Duration `protobuf:"bytes,3,opt,name=duration,proto3" json:"duration,omitempty"` CurrentEpoch int64 `protobuf:"varint,4,opt,name=current_epoch,json=currentEpoch,proto3" json:"current_epoch,omitempty"` CurrentEpochStartTime *timestamppb.Timestamp `` /* 128-byte string literal not displayed */ EpochCountingStarted bool `protobuf:"varint,6,opt,name=epoch_counting_started,json=epochCountingStarted,proto3" json:"epoch_counting_started,omitempty"` CurrentEpochStartHeight int64 `` /* 135-byte string literal not displayed */ // contains filtered or unexported fields }
func (*EpochInfo) Descriptor
deprecated
func (*EpochInfo) GetCurrentEpoch ¶
func (*EpochInfo) GetCurrentEpochStartHeight ¶
func (*EpochInfo) GetCurrentEpochStartTime ¶
func (x *EpochInfo) GetCurrentEpochStartTime() *timestamppb.Timestamp
func (*EpochInfo) GetDuration ¶
func (x *EpochInfo) GetDuration() *durationpb.Duration
func (*EpochInfo) GetEpochCountingStarted ¶
func (*EpochInfo) GetIdentifier ¶
func (*EpochInfo) GetStartTime ¶
func (x *EpochInfo) GetStartTime() *timestamppb.Timestamp
func (*EpochInfo) ProtoMessage ¶
func (*EpochInfo) ProtoMessage()
func (*EpochInfo) ProtoReflect ¶
func (x *EpochInfo) ProtoReflect() protoreflect.Message
type GenesisState ¶
type GenesisState struct { Epochs []*EpochInfo `protobuf:"bytes,1,rep,name=epochs,proto3" json:"epochs,omitempty"` // contains filtered or unexported fields }
GenesisState defines the epochs module's genesis state.
func (*GenesisState) Descriptor
deprecated
func (*GenesisState) Descriptor() ([]byte, []int)
Deprecated: Use GenesisState.ProtoReflect.Descriptor instead.
func (*GenesisState) GetEpochs ¶
func (x *GenesisState) GetEpochs() []*EpochInfo
func (*GenesisState) ProtoMessage ¶
func (*GenesisState) ProtoMessage()
func (*GenesisState) ProtoReflect ¶
func (x *GenesisState) ProtoReflect() protoreflect.Message
func (*GenesisState) Reset ¶
func (x *GenesisState) Reset()
func (*GenesisState) String ¶
func (x *GenesisState) String() string
type QueryClient ¶
type QueryClient interface { // EpochInfos provide running epochInfos EpochInfos(ctx context.Context, in *QueryEpochsInfoRequest, opts ...grpc.CallOption) (*QueryEpochsInfoResponse, error) // CurrentEpoch provide current epoch of specified identifier CurrentEpoch(ctx context.Context, in *QueryCurrentEpochRequest, opts ...grpc.CallOption) (*QueryCurrentEpochResponse, error) }
QueryClient is the client API for Query 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 NewQueryClient ¶
func NewQueryClient(cc grpc.ClientConnInterface) QueryClient
type QueryCurrentEpochRequest ¶
type QueryCurrentEpochRequest struct { Identifier string `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"` // contains filtered or unexported fields }
func (*QueryCurrentEpochRequest) Descriptor
deprecated
func (*QueryCurrentEpochRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryCurrentEpochRequest.ProtoReflect.Descriptor instead.
func (*QueryCurrentEpochRequest) GetIdentifier ¶
func (x *QueryCurrentEpochRequest) GetIdentifier() string
func (*QueryCurrentEpochRequest) ProtoMessage ¶
func (*QueryCurrentEpochRequest) ProtoMessage()
func (*QueryCurrentEpochRequest) ProtoReflect ¶
func (x *QueryCurrentEpochRequest) ProtoReflect() protoreflect.Message
func (*QueryCurrentEpochRequest) Reset ¶
func (x *QueryCurrentEpochRequest) Reset()
func (*QueryCurrentEpochRequest) String ¶
func (x *QueryCurrentEpochRequest) String() string
type QueryCurrentEpochResponse ¶
type QueryCurrentEpochResponse struct { CurrentEpoch int64 `protobuf:"varint,1,opt,name=current_epoch,json=currentEpoch,proto3" json:"current_epoch,omitempty"` // contains filtered or unexported fields }
func (*QueryCurrentEpochResponse) Descriptor
deprecated
func (*QueryCurrentEpochResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryCurrentEpochResponse.ProtoReflect.Descriptor instead.
func (*QueryCurrentEpochResponse) GetCurrentEpoch ¶
func (x *QueryCurrentEpochResponse) GetCurrentEpoch() int64
func (*QueryCurrentEpochResponse) ProtoMessage ¶
func (*QueryCurrentEpochResponse) ProtoMessage()
func (*QueryCurrentEpochResponse) ProtoReflect ¶
func (x *QueryCurrentEpochResponse) ProtoReflect() protoreflect.Message
func (*QueryCurrentEpochResponse) Reset ¶
func (x *QueryCurrentEpochResponse) Reset()
func (*QueryCurrentEpochResponse) String ¶
func (x *QueryCurrentEpochResponse) String() string
type QueryEpochsInfoRequest ¶
type QueryEpochsInfoRequest struct { Pagination *v1beta1.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"` // contains filtered or unexported fields }
func (*QueryEpochsInfoRequest) Descriptor
deprecated
func (*QueryEpochsInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryEpochsInfoRequest.ProtoReflect.Descriptor instead.
func (*QueryEpochsInfoRequest) GetPagination ¶
func (x *QueryEpochsInfoRequest) GetPagination() *v1beta1.PageRequest
func (*QueryEpochsInfoRequest) ProtoMessage ¶
func (*QueryEpochsInfoRequest) ProtoMessage()
func (*QueryEpochsInfoRequest) ProtoReflect ¶
func (x *QueryEpochsInfoRequest) ProtoReflect() protoreflect.Message
func (*QueryEpochsInfoRequest) Reset ¶
func (x *QueryEpochsInfoRequest) Reset()
func (*QueryEpochsInfoRequest) String ¶
func (x *QueryEpochsInfoRequest) String() string
type QueryEpochsInfoResponse ¶
type QueryEpochsInfoResponse struct { Epochs []*EpochInfo `protobuf:"bytes,1,rep,name=epochs,proto3" json:"epochs,omitempty"` Pagination *v1beta1.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"` // contains filtered or unexported fields }
func (*QueryEpochsInfoResponse) Descriptor
deprecated
func (*QueryEpochsInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryEpochsInfoResponse.ProtoReflect.Descriptor instead.
func (*QueryEpochsInfoResponse) GetEpochs ¶
func (x *QueryEpochsInfoResponse) GetEpochs() []*EpochInfo
func (*QueryEpochsInfoResponse) GetPagination ¶
func (x *QueryEpochsInfoResponse) GetPagination() *v1beta1.PageResponse
func (*QueryEpochsInfoResponse) ProtoMessage ¶
func (*QueryEpochsInfoResponse) ProtoMessage()
func (*QueryEpochsInfoResponse) ProtoReflect ¶
func (x *QueryEpochsInfoResponse) ProtoReflect() protoreflect.Message
func (*QueryEpochsInfoResponse) Reset ¶
func (x *QueryEpochsInfoResponse) Reset()
func (*QueryEpochsInfoResponse) String ¶
func (x *QueryEpochsInfoResponse) String() string
type QueryServer ¶
type QueryServer interface { // EpochInfos provide running epochInfos EpochInfos(context.Context, *QueryEpochsInfoRequest) (*QueryEpochsInfoResponse, error) // CurrentEpoch provide current epoch of specified identifier CurrentEpoch(context.Context, *QueryCurrentEpochRequest) (*QueryCurrentEpochResponse, error) // contains filtered or unexported methods }
QueryServer is the server API for Query service. All implementations must embed UnimplementedQueryServer for forward compatibility
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer must be embedded to have forward compatible implementations.
func (UnimplementedQueryServer) CurrentEpoch ¶
func (UnimplementedQueryServer) CurrentEpoch(context.Context, *QueryCurrentEpochRequest) (*QueryCurrentEpochResponse, error)
func (UnimplementedQueryServer) EpochInfos ¶
func (UnimplementedQueryServer) EpochInfos(context.Context, *QueryEpochsInfoRequest) (*QueryEpochsInfoResponse, error)
type UnsafeQueryServer ¶
type UnsafeQueryServer interface {
// contains filtered or unexported methods
}
UnsafeQueryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueryServer will result in compilation errors.