Documentation
¶
Overview ¶
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Index ¶
- 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 ¶
This section is empty.
Variables ¶
var File_elys_epochs_v1_genesis_proto protoreflect.FileDescriptor
var File_elys_epochs_v1_query_proto protoreflect.FileDescriptor
var Query_ServiceDesc = grpc.ServiceDesc{ ServiceName: "elys.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: "elys/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 of the epoch
Identifier string `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
// start_time of the epoch
StartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
// duration of the epoch
Duration *durationpb.Duration `protobuf:"bytes,3,opt,name=duration,proto3" json:"duration,omitempty"`
// current_epoch is the integer identifier of the epoch
CurrentEpoch int64 `protobuf:"varint,4,opt,name=current_epoch,json=currentEpoch,proto3" json:"current_epoch,omitempty"`
// current_epoch_start_time defines the timestamp of the start of the epoch
CurrentEpochStartTime *timestamppb.Timestamp `` /* 128-byte string literal not displayed */
// epoch_counting_started reflects if the counting for the epoch has started
EpochCountingStarted bool `protobuf:"varint,6,opt,name=epoch_counting_started,json=epochCountingStarted,proto3" json:"epoch_counting_started,omitempty"`
// current_epoch_start_height of the epoch
CurrentEpochStartHeight int64 `` /* 135-byte string literal not displayed */
// contains filtered or unexported fields
}
EpochInfo defines the message interface containing the relevant informations about an epoch.
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 is a slice of EpochInfo that defines the epochs in the genesis state
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 of the current epoch
Identifier string `protobuf:"bytes,1,opt,name=identifier,proto3" json:"identifier,omitempty"`
// contains filtered or unexported fields
}
QueryCurrentEpochRequest is the request type for the Query/EpochInfos RPC method.
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 {
// current_epoch is the number of the current epoch
CurrentEpoch int64 `protobuf:"varint,1,opt,name=current_epoch,json=currentEpoch,proto3" json:"current_epoch,omitempty"`
// contains filtered or unexported fields
}
QueryCurrentEpochResponse is the response type for the Query/EpochInfos RPC method.
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 defines an optional pagination for the request.
Pagination *v1beta1.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
// contains filtered or unexported fields
}
QueryEpochsInfoRequest is the request type for the Query/EpochInfos RPC method.
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 is a slice of all EpochInfos
Epochs []*EpochInfo `protobuf:"bytes,1,rep,name=epochs,proto3" json:"epochs,omitempty"`
// pagination defines an optional pagination for the request.
Pagination *v1beta1.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
// contains filtered or unexported fields
}
QueryEpochsInfoResponse is the response type for the Query/EpochInfos RPC method.
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.