Versions in this module Expand all Collapse all v1 v1.0.0 Feb 26, 2023 Changes in this version + const AttributeEpochNumber + const AttributeEpochStartTime + const DayEpochID + const EventTypeEpochEnd + const EventTypeEpochStart + const HourEpochID + const ModuleName + const RouterKey + const StoreKey + const WeekEpochID + var ErrIntOverflowGenesis = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthGenesis = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") + var KeyPrefixEpoch = []byte + var ModuleCdc = codec.NewProtoCodec(codectypes.NewInterfaceRegistry()) + func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error + func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error + func RegisterQueryServer(s grpc1.Server, srv QueryServer) + func ValidateEpochIdentifierInterface(i interface{}) error + func ValidateEpochIdentifierString(s string) error + type EpochHooks interface + AfterEpochEnd func(ctx sdk.Context, epochIdentifier string, epochNumber int64) + BeforeEpochStart func(ctx sdk.Context, epochIdentifier string, epochNumber int64) + type EpochInfo struct + CurrentEpoch int64 + CurrentEpochStartHeight int64 + CurrentEpochStartTime time.Time + Duration time.Duration + EpochCountingStarted bool + Identifier string + StartTime time.Time + func (*EpochInfo) Descriptor() ([]byte, []int) + func (*EpochInfo) ProtoMessage() + func (ei *EpochInfo) EndEpoch() + func (ei *EpochInfo) StartInitialEpoch() + func (ei EpochInfo) Validate() error + func (m *EpochInfo) GetCurrentEpoch() int64 + func (m *EpochInfo) GetCurrentEpochStartHeight() int64 + func (m *EpochInfo) GetCurrentEpochStartTime() time.Time + func (m *EpochInfo) GetDuration() time.Duration + func (m *EpochInfo) GetEpochCountingStarted() bool + func (m *EpochInfo) GetIdentifier() string + func (m *EpochInfo) GetStartTime() time.Time + func (m *EpochInfo) Marshal() (dAtA []byte, err error) + func (m *EpochInfo) MarshalTo(dAtA []byte) (int, error) + func (m *EpochInfo) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *EpochInfo) Reset() + func (m *EpochInfo) Size() (n int) + func (m *EpochInfo) String() string + func (m *EpochInfo) Unmarshal(dAtA []byte) error + func (m *EpochInfo) XXX_DiscardUnknown() + func (m *EpochInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *EpochInfo) XXX_Merge(src proto.Message) + func (m *EpochInfo) XXX_Size() int + func (m *EpochInfo) XXX_Unmarshal(b []byte) error + type GenesisState struct + Epochs []EpochInfo + func DefaultGenesisState() *GenesisState + func NewGenesisState(epochs []EpochInfo) *GenesisState + func (*GenesisState) Descriptor() ([]byte, []int) + func (*GenesisState) ProtoMessage() + func (gs GenesisState) Validate() error + func (m *GenesisState) GetEpochs() []EpochInfo + func (m *GenesisState) Marshal() (dAtA []byte, err error) + func (m *GenesisState) MarshalTo(dAtA []byte) (int, error) + func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GenesisState) Reset() + func (m *GenesisState) Size() (n int) + func (m *GenesisState) String() string + func (m *GenesisState) Unmarshal(dAtA []byte) error + func (m *GenesisState) XXX_DiscardUnknown() + func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GenesisState) XXX_Merge(src proto.Message) + func (m *GenesisState) XXX_Size() int + func (m *GenesisState) XXX_Unmarshal(b []byte) error + type QueryClient interface + CurrentEpoch func(ctx context.Context, in *QueryCurrentEpochRequest, opts ...grpc.CallOption) (*QueryCurrentEpochResponse, error) + EpochInfos func(ctx context.Context, in *QueryEpochsInfoRequest, opts ...grpc.CallOption) (*QueryEpochsInfoResponse, error) + func NewQueryClient(cc grpc1.ClientConn) QueryClient + type QueryCurrentEpochRequest struct + Identifier string + func (*QueryCurrentEpochRequest) Descriptor() ([]byte, []int) + func (*QueryCurrentEpochRequest) ProtoMessage() + func (m *QueryCurrentEpochRequest) GetIdentifier() string + func (m *QueryCurrentEpochRequest) Marshal() (dAtA []byte, err error) + func (m *QueryCurrentEpochRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryCurrentEpochRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryCurrentEpochRequest) Reset() + func (m *QueryCurrentEpochRequest) Size() (n int) + func (m *QueryCurrentEpochRequest) String() string + func (m *QueryCurrentEpochRequest) Unmarshal(dAtA []byte) error + func (m *QueryCurrentEpochRequest) XXX_DiscardUnknown() + func (m *QueryCurrentEpochRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryCurrentEpochRequest) XXX_Merge(src proto.Message) + func (m *QueryCurrentEpochRequest) XXX_Size() int + func (m *QueryCurrentEpochRequest) XXX_Unmarshal(b []byte) error + type QueryCurrentEpochResponse struct + CurrentEpoch int64 + func (*QueryCurrentEpochResponse) Descriptor() ([]byte, []int) + func (*QueryCurrentEpochResponse) ProtoMessage() + func (m *QueryCurrentEpochResponse) GetCurrentEpoch() int64 + func (m *QueryCurrentEpochResponse) Marshal() (dAtA []byte, err error) + func (m *QueryCurrentEpochResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryCurrentEpochResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryCurrentEpochResponse) Reset() + func (m *QueryCurrentEpochResponse) Size() (n int) + func (m *QueryCurrentEpochResponse) String() string + func (m *QueryCurrentEpochResponse) Unmarshal(dAtA []byte) error + func (m *QueryCurrentEpochResponse) XXX_DiscardUnknown() + func (m *QueryCurrentEpochResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryCurrentEpochResponse) XXX_Merge(src proto.Message) + func (m *QueryCurrentEpochResponse) XXX_Size() int + func (m *QueryCurrentEpochResponse) XXX_Unmarshal(b []byte) error + type QueryEpochsInfoRequest struct + Pagination *query.PageRequest + func (*QueryEpochsInfoRequest) Descriptor() ([]byte, []int) + func (*QueryEpochsInfoRequest) ProtoMessage() + func (m *QueryEpochsInfoRequest) GetPagination() *query.PageRequest + func (m *QueryEpochsInfoRequest) Marshal() (dAtA []byte, err error) + func (m *QueryEpochsInfoRequest) MarshalTo(dAtA []byte) (int, error) + func (m *QueryEpochsInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryEpochsInfoRequest) Reset() + func (m *QueryEpochsInfoRequest) Size() (n int) + func (m *QueryEpochsInfoRequest) String() string + func (m *QueryEpochsInfoRequest) Unmarshal(dAtA []byte) error + func (m *QueryEpochsInfoRequest) XXX_DiscardUnknown() + func (m *QueryEpochsInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryEpochsInfoRequest) XXX_Merge(src proto.Message) + func (m *QueryEpochsInfoRequest) XXX_Size() int + func (m *QueryEpochsInfoRequest) XXX_Unmarshal(b []byte) error + type QueryEpochsInfoResponse struct + Epochs []EpochInfo + Pagination *query.PageResponse + func (*QueryEpochsInfoResponse) Descriptor() ([]byte, []int) + func (*QueryEpochsInfoResponse) ProtoMessage() + func (m *QueryEpochsInfoResponse) GetEpochs() []EpochInfo + func (m *QueryEpochsInfoResponse) GetPagination() *query.PageResponse + func (m *QueryEpochsInfoResponse) Marshal() (dAtA []byte, err error) + func (m *QueryEpochsInfoResponse) MarshalTo(dAtA []byte) (int, error) + func (m *QueryEpochsInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *QueryEpochsInfoResponse) Reset() + func (m *QueryEpochsInfoResponse) Size() (n int) + func (m *QueryEpochsInfoResponse) String() string + func (m *QueryEpochsInfoResponse) Unmarshal(dAtA []byte) error + func (m *QueryEpochsInfoResponse) XXX_DiscardUnknown() + func (m *QueryEpochsInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *QueryEpochsInfoResponse) XXX_Merge(src proto.Message) + func (m *QueryEpochsInfoResponse) XXX_Size() int + func (m *QueryEpochsInfoResponse) XXX_Unmarshal(b []byte) error + type QueryServer interface + CurrentEpoch func(context.Context, *QueryCurrentEpochRequest) (*QueryCurrentEpochResponse, error) + EpochInfos func(context.Context, *QueryEpochsInfoRequest) (*QueryEpochsInfoResponse, error) + type UnimplementedQueryServer struct + func (*UnimplementedQueryServer) CurrentEpoch(ctx context.Context, req *QueryCurrentEpochRequest) (*QueryCurrentEpochResponse, error) + func (*UnimplementedQueryServer) EpochInfos(ctx context.Context, req *QueryEpochsInfoRequest) (*QueryEpochsInfoResponse, error)
Go to main page