Documentation ¶
Overview ¶
Package types is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func AssertSanitizedIndex(safeIndex SafeIndex, prefix string)
- func DecodeBlockAndKey(encodedKey []byte) (uint64, []byte)
- func DecodeKey(encodedKey []byte) uint64
- func DesanitizeIndex(safeIndex SafeIndex) string
- func EncodeBlockAndKey(block uint64, key []byte) []byte
- func EncodeKey(key uint64) []byte
- func FixationVersion() uint64
- func IsEntryIndexLive(value []byte) bool
- func KeyPrefix(p string) []byte
- 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)
- type Entry
- func (*Entry) Descriptor() ([]byte, []int)
- func (m *Entry) GetBlock() uint64
- func (m *Entry) GetData() []byte
- func (m *Entry) GetDeleteAt() uint64
- func (m *Entry) GetIndex() string
- func (m *Entry) GetIsLatest() bool
- func (m *Entry) GetRefcount() uint64
- func (m *Entry) GetStaleAt() uint64
- func (entry Entry) HasDeleteAt() bool
- func (entry Entry) IsDeleted(ctx sdk.Context) bool
- func (entry Entry) IsDeletedBy(block uint64) bool
- func (entry Entry) IsStale(ctx sdk.Context) bool
- func (entry Entry) IsStaleBy(block uint64) bool
- func (m *Entry) Marshal() (dAtA []byte, err error)
- func (m *Entry) MarshalTo(dAtA []byte) (int, error)
- func (m *Entry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Entry) ProtoMessage()
- func (m *Entry) Reset()
- func (entry Entry) SafeIndex() SafeIndex
- func (m *Entry) Size() (n int)
- func (m *Entry) String() string
- func (m *Entry) Unmarshal(dAtA []byte) error
- func (m *Entry) XXX_DiscardUnknown()
- func (m *Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Entry) XXX_Merge(src proto.Message)
- func (m *Entry) XXX_Size() int
- func (m *Entry) XXX_Unmarshal(b []byte) error
- type EpochstorageKeeper
- type FixationStore
- func (fs FixationStore) AllEntryIndicesFilter(ctx sdk.Context, prefix string, filter func(k, v []byte) bool) []string
- func (fs *FixationStore) AppendEntry(ctx sdk.Context, index string, block uint64, entryData codec.ProtoMarshaler) error
- func (fs *FixationStore) DelEntry(ctx sdk.Context, index string, block uint64) error
- func (fs *FixationStore) Export(ctx sdk.Context) GenesisState
- func (fs *FixationStore) FindEntry(ctx sdk.Context, index string, block uint64, entryData codec.ProtoMarshaler) bool
- func (fs *FixationStore) FindEntryDetailed(ctx sdk.Context, index string, block uint64, entryData codec.ProtoMarshaler) (entryBlock uint64, isDeleted bool, isLatest bool, found bool)
- func (fs *FixationStore) FindRawEntry(ctx sdk.Context, index string, block uint64) (Entry, error)
- func (fs FixationStore) GetAllEntryIndices(ctx sdk.Context) []string
- func (fs FixationStore) GetAllEntryIndicesWithPrefix(ctx sdk.Context, prefix string) []string
- func (fs *FixationStore) GetAllEntryVersions(ctx sdk.Context, index string) (blocks []uint64)
- func (fs *FixationStore) GetEntry(ctx sdk.Context, index string, entryData codec.ProtoMarshaler) bool
- func (fs *FixationStore) GetEntryVersionsRange(ctx sdk.Context, index string, block, delta uint64) (blocks []uint64)
- func (fs *FixationStore) GetStoreKey() storetypes.StoreKey
- func (fs *FixationStore) GetStorePrefix() string
- func (fs *FixationStore) HasEntry(ctx sdk.Context, index string, block uint64) bool
- func (fs *FixationStore) Init(ctx sdk.Context, gs GenesisState)
- func (fs *FixationStore) IsEntryStale(ctx sdk.Context, index string, block uint64) bool
- func (fs *FixationStore) ModifyEntry(ctx sdk.Context, index string, block uint64, entryData codec.ProtoMarshaler)
- func (fs *FixationStore) PutEntry(ctx sdk.Context, index string, block uint64)
- func (fs *FixationStore) ReadEntry(ctx sdk.Context, index string, block uint64, entryData codec.ProtoMarshaler)
- type GenesisEntries
- func (*GenesisEntries) Descriptor() ([]byte, []int)
- func (m *GenesisEntries) GetEntries() []Entry
- func (m *GenesisEntries) GetIndex() string
- func (m *GenesisEntries) GetIsLive() bool
- func (m *GenesisEntries) Marshal() (dAtA []byte, err error)
- func (m *GenesisEntries) MarshalTo(dAtA []byte) (int, error)
- func (m *GenesisEntries) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GenesisEntries) ProtoMessage()
- func (m *GenesisEntries) Reset()
- func (m *GenesisEntries) Size() (n int)
- func (m *GenesisEntries) String() string
- func (m *GenesisEntries) Unmarshal(dAtA []byte) error
- func (m *GenesisEntries) XXX_DiscardUnknown()
- func (m *GenesisEntries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GenesisEntries) XXX_Merge(src proto.Message)
- func (m *GenesisEntries) XXX_Size() int
- func (m *GenesisEntries) XXX_Unmarshal(b []byte) error
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)
- func (m *GenesisState) GetEntries() []GenesisEntries
- func (m *GenesisState) GetTimerstore() types.GenesisState
- func (m *GenesisState) GetVersion() uint64
- 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 (*GenesisState) ProtoMessage()
- 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 GetStaleBlocks
- type QueryAllIndicesRequest
- func (*QueryAllIndicesRequest) Descriptor() ([]byte, []int)
- func (m *QueryAllIndicesRequest) GetPrefix() string
- func (m *QueryAllIndicesRequest) GetStoreKey() string
- func (m *QueryAllIndicesRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryAllIndicesRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryAllIndicesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryAllIndicesRequest) ProtoMessage()
- func (m *QueryAllIndicesRequest) Reset()
- func (m *QueryAllIndicesRequest) Size() (n int)
- func (m *QueryAllIndicesRequest) String() string
- func (m *QueryAllIndicesRequest) Unmarshal(dAtA []byte) error
- func (m *QueryAllIndicesRequest) XXX_DiscardUnknown()
- func (m *QueryAllIndicesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryAllIndicesRequest) XXX_Merge(src proto.Message)
- func (m *QueryAllIndicesRequest) XXX_Size() int
- func (m *QueryAllIndicesRequest) XXX_Unmarshal(b []byte) error
- type QueryAllIndicesResponse
- func (*QueryAllIndicesResponse) Descriptor() ([]byte, []int)
- func (m *QueryAllIndicesResponse) GetIndices() []string
- func (m *QueryAllIndicesResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryAllIndicesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryAllIndicesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryAllIndicesResponse) ProtoMessage()
- func (m *QueryAllIndicesResponse) Reset()
- func (m *QueryAllIndicesResponse) Size() (n int)
- func (m *QueryAllIndicesResponse) String() string
- func (m *QueryAllIndicesResponse) Unmarshal(dAtA []byte) error
- func (m *QueryAllIndicesResponse) XXX_DiscardUnknown()
- func (m *QueryAllIndicesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryAllIndicesResponse) XXX_Merge(src proto.Message)
- func (m *QueryAllIndicesResponse) XXX_Size() int
- func (m *QueryAllIndicesResponse) XXX_Unmarshal(b []byte) error
- type QueryClient
- type QueryEntryRequest
- func (*QueryEntryRequest) Descriptor() ([]byte, []int)
- func (m *QueryEntryRequest) GetBlock() uint64
- func (m *QueryEntryRequest) GetHideData() bool
- func (m *QueryEntryRequest) GetKey() string
- func (m *QueryEntryRequest) GetPrefix() string
- func (m *QueryEntryRequest) GetStoreKey() string
- func (m *QueryEntryRequest) GetStringData() bool
- func (m *QueryEntryRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryEntryRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryEntryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryEntryRequest) ProtoMessage()
- func (m *QueryEntryRequest) Reset()
- func (m *QueryEntryRequest) Size() (n int)
- func (m *QueryEntryRequest) String() string
- func (m *QueryEntryRequest) Unmarshal(dAtA []byte) error
- func (m *QueryEntryRequest) XXX_DiscardUnknown()
- func (m *QueryEntryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryEntryRequest) XXX_Merge(src proto.Message)
- func (m *QueryEntryRequest) XXX_Size() int
- func (m *QueryEntryRequest) XXX_Unmarshal(b []byte) error
- type QueryEntryResponse
- func (*QueryEntryResponse) Descriptor() ([]byte, []int)
- func (m *QueryEntryResponse) GetEntry() *Entry
- func (m *QueryEntryResponse) GetStringData() string
- func (m *QueryEntryResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryEntryResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryEntryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryEntryResponse) ProtoMessage()
- func (m *QueryEntryResponse) Reset()
- func (m *QueryEntryResponse) Size() (n int)
- func (m *QueryEntryResponse) String() string
- func (m *QueryEntryResponse) Unmarshal(dAtA []byte) error
- func (m *QueryEntryResponse) XXX_DiscardUnknown()
- func (m *QueryEntryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryEntryResponse) XXX_Merge(src proto.Message)
- func (m *QueryEntryResponse) XXX_Size() int
- func (m *QueryEntryResponse) XXX_Unmarshal(b []byte) error
- type QueryServer
- type QueryStoreKeysRequest
- func (*QueryStoreKeysRequest) Descriptor() ([]byte, []int)
- func (m *QueryStoreKeysRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryStoreKeysRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryStoreKeysRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryStoreKeysRequest) ProtoMessage()
- func (m *QueryStoreKeysRequest) Reset()
- func (m *QueryStoreKeysRequest) Size() (n int)
- func (m *QueryStoreKeysRequest) String() string
- func (m *QueryStoreKeysRequest) Unmarshal(dAtA []byte) error
- func (m *QueryStoreKeysRequest) XXX_DiscardUnknown()
- func (m *QueryStoreKeysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryStoreKeysRequest) XXX_Merge(src proto.Message)
- func (m *QueryStoreKeysRequest) XXX_Size() int
- func (m *QueryStoreKeysRequest) XXX_Unmarshal(b []byte) error
- type QueryStoreKeysResponse
- func (*QueryStoreKeysResponse) Descriptor() ([]byte, []int)
- func (m *QueryStoreKeysResponse) GetKeys() []StoreKeyAndPrefix
- func (m *QueryStoreKeysResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryStoreKeysResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryStoreKeysResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryStoreKeysResponse) ProtoMessage()
- func (m *QueryStoreKeysResponse) Reset()
- func (m *QueryStoreKeysResponse) Size() (n int)
- func (m *QueryStoreKeysResponse) String() string
- func (m *QueryStoreKeysResponse) Unmarshal(dAtA []byte) error
- func (m *QueryStoreKeysResponse) XXX_DiscardUnknown()
- func (m *QueryStoreKeysResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryStoreKeysResponse) XXX_Merge(src proto.Message)
- func (m *QueryStoreKeysResponse) XXX_Size() int
- func (m *QueryStoreKeysResponse) XXX_Unmarshal(b []byte) error
- type QueryVersionsRequest
- func (*QueryVersionsRequest) Descriptor() ([]byte, []int)
- func (m *QueryVersionsRequest) GetKey() string
- func (m *QueryVersionsRequest) GetPrefix() string
- func (m *QueryVersionsRequest) GetStoreKey() string
- func (m *QueryVersionsRequest) Marshal() (dAtA []byte, err error)
- func (m *QueryVersionsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryVersionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryVersionsRequest) ProtoMessage()
- func (m *QueryVersionsRequest) Reset()
- func (m *QueryVersionsRequest) Size() (n int)
- func (m *QueryVersionsRequest) String() string
- func (m *QueryVersionsRequest) Unmarshal(dAtA []byte) error
- func (m *QueryVersionsRequest) XXX_DiscardUnknown()
- func (m *QueryVersionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryVersionsRequest) XXX_Merge(src proto.Message)
- func (m *QueryVersionsRequest) XXX_Size() int
- func (m *QueryVersionsRequest) XXX_Unmarshal(b []byte) error
- type QueryVersionsResponse
- func (*QueryVersionsResponse) Descriptor() ([]byte, []int)
- func (m *QueryVersionsResponse) GetEntries() []Entry
- func (m *QueryVersionsResponse) Marshal() (dAtA []byte, err error)
- func (m *QueryVersionsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *QueryVersionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*QueryVersionsResponse) ProtoMessage()
- func (m *QueryVersionsResponse) Reset()
- func (m *QueryVersionsResponse) Size() (n int)
- func (m *QueryVersionsResponse) String() string
- func (m *QueryVersionsResponse) Unmarshal(dAtA []byte) error
- func (m *QueryVersionsResponse) XXX_DiscardUnknown()
- func (m *QueryVersionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *QueryVersionsResponse) XXX_Merge(src proto.Message)
- func (m *QueryVersionsResponse) XXX_Size() int
- func (m *QueryVersionsResponse) XXX_Unmarshal(b []byte) error
- type SafeIndex
- type StoreKeyAndPrefix
- func (*StoreKeyAndPrefix) Descriptor() ([]byte, []int)
- func (m *StoreKeyAndPrefix) GetPrefix() string
- func (m *StoreKeyAndPrefix) GetStoreKey() string
- func (m *StoreKeyAndPrefix) Marshal() (dAtA []byte, err error)
- func (m *StoreKeyAndPrefix) MarshalTo(dAtA []byte) (int, error)
- func (m *StoreKeyAndPrefix) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StoreKeyAndPrefix) ProtoMessage()
- func (m *StoreKeyAndPrefix) Reset()
- func (m *StoreKeyAndPrefix) Size() (n int)
- func (m *StoreKeyAndPrefix) String() string
- func (m *StoreKeyAndPrefix) Unmarshal(dAtA []byte) error
- func (m *StoreKeyAndPrefix) XXX_DiscardUnknown()
- func (m *StoreKeyAndPrefix) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StoreKeyAndPrefix) XXX_Merge(src proto.Message)
- func (m *StoreKeyAndPrefix) XXX_Size() int
- func (m *StoreKeyAndPrefix) XXX_Unmarshal(b []byte) error
- type UnimplementedQueryServer
- func (*UnimplementedQueryServer) AllIndices(ctx context.Context, req *QueryAllIndicesRequest) (*QueryAllIndicesResponse, error)
- func (*UnimplementedQueryServer) Entry(ctx context.Context, req *QueryEntryRequest) (*QueryEntryResponse, error)
- func (*UnimplementedQueryServer) StoreKeys(ctx context.Context, req *QueryStoreKeysRequest) (*QueryStoreKeysResponse, error)
- func (*UnimplementedQueryServer) Versions(ctx context.Context, req *QueryVersionsRequest) (*QueryVersionsResponse, error)
Constants ¶
const ( EntryIndexPrefix = "Entry_Index_" EntryPrefix = "Entry_Value_" )
const (
MODULE_NAME string = "fixationstore"
)
const (
ModuleName = "fixationstore"
)
Variables ¶
var ( ErrInvalidLengthFixation = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowFixation = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupFixation = fmt.Errorf("proto: unexpected end of group") )
var ( // use single byte to save storage. // (value cannot be part of a valid index) EntryIndexLive = []byte{1} EntryIndexDead = []byte{2} )
var ( ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group") )
var (
ErrInvalidIndex = sdkerrors.Register(MODULE_NAME, 1, "entry index is invalid")
)
x/pairing module sentinel errors
Functions ¶
func AssertSanitizedIndex ¶
func DecodeBlockAndKey ¶
func DesanitizeIndex ¶
desantizeIndex reverts the effect of SanitizeIndex - removes the trailing (ascii) DEL terminator.
func EncodeBlockAndKey ¶
func FixationVersion ¶
func FixationVersion() uint64
func IsEntryIndexLive ¶
IsEntryIndexLive tests whether an entry-index is live
func RegisterQueryHandler ¶
RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterQueryHandlerClient ¶
func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error
RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.
func RegisterQueryHandlerFromEndpoint ¶
func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterQueryHandlerServer ¶
func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error
RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc1.Server, srv QueryServer)
Types ¶
type Entry ¶
type Entry struct { Index string `protobuf:"bytes,1,opt,name=index,proto3" json:"index,omitempty"` Block uint64 `protobuf:"varint,2,opt,name=block,proto3" json:"block,omitempty"` StaleAt uint64 `protobuf:"varint,3,opt,name=stale_at,json=staleAt,proto3" json:"stale_at,omitempty"` Refcount uint64 `protobuf:"varint,4,opt,name=refcount,proto3" json:"refcount,omitempty"` Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"` DeleteAt uint64 `protobuf:"varint,6,opt,name=delete_at,json=deleteAt,proto3" json:"delete_at,omitempty"` IsLatest bool `protobuf:"varint,7,opt,name=is_latest,json=isLatest,proto3" json:"is_latest,omitempty"` }
func (*Entry) Descriptor ¶
func (*Entry) GetDeleteAt ¶
func (*Entry) GetIsLatest ¶
func (*Entry) GetRefcount ¶
func (*Entry) GetStaleAt ¶
func (Entry) HasDeleteAt ¶
HasDeleteAt tests whether an entry is marked for deletion, i.e. has entry.Deleted != math.MaxUint64.
func (Entry) IsDeleted ¶
IsDeleted tests whether an entry is currently deleted, i.e. has its entry.DeleteAt below the current ctx block height.
func (Entry) IsDeletedBy ¶
IsDeletedBy tests whether an entry is deleted, with respect to a given block, i.e. has entry.DeletAt smaller or equal to that that block.
func (Entry) IsStale ¶
IsStale tests whether an entry is currently stale, i.e. has refcount zero _and_ has passed its stale_at time (more than STALE_ENTRY_TIME since deletion).
func (Entry) IsStaleBy ¶
IsStaleBy tests whether an entry is stale, i.e. has refcount zero _and_ has passed its stale_at time (more than STALE_ENTRY_TIME since deletion).
func (*Entry) ProtoMessage ¶
func (*Entry) ProtoMessage()
func (*Entry) XXX_DiscardUnknown ¶
func (m *Entry) XXX_DiscardUnknown()
func (*Entry) XXX_Marshal ¶
func (*Entry) XXX_Unmarshal ¶
type EpochstorageKeeper ¶
type FixationStore ¶
type FixationStore struct {
// contains filtered or unexported fields
}
func NewFixationStore ¶
func NewFixationStore(storeKey storetypes.StoreKey, cdc codec.BinaryCodec, prefix string, tstore *timerstoretypes.TimerStore, getStaleBlocks GetStaleBlocks) *FixationStore
NewFixationStore returns a new FixationStore object
func (FixationStore) AllEntryIndicesFilter ¶
func (fs FixationStore) AllEntryIndicesFilter(ctx sdk.Context, prefix string, filter func(k, v []byte) bool) []string
AllEntryIndicesFilter returns all Entry indices with a given prefix and filtered by the given filter function.
func (*FixationStore) AppendEntry ¶
func (fs *FixationStore) AppendEntry( ctx sdk.Context, index string, block uint64, entryData codec.ProtoMarshaler, ) error
AppendEntry adds a new entry to the store
func (*FixationStore) DelEntry ¶
DelEntry marks the entry for deletion so that future GetEntry will not find it anymore. (Cleanup of the EntryIndex is done when the last reference is removed).
func (*FixationStore) Export ¶
func (fs *FixationStore) Export(ctx sdk.Context) GenesisState
func (*FixationStore) FindEntry ¶
func (fs *FixationStore) FindEntry(ctx sdk.Context, index string, block uint64, entryData codec.ProtoMarshaler) bool
FindEntry returns the entry by index and block without changing the refcount
func (*FixationStore) FindEntryDetailed ¶
func (fs *FixationStore) FindEntryDetailed(ctx sdk.Context, index string, block uint64, entryData codec.ProtoMarshaler) (entryBlock uint64, isDeleted bool, isLatest bool, found bool)
FindEntryDetailed returns the entry by index, whether it's deleted, and block without changing the refcount
func (*FixationStore) FindRawEntry ¶
FindRawEntry returns the raw entry by index and block (even deleted or stale entries)
func (FixationStore) GetAllEntryIndices ¶
func (fs FixationStore) GetAllEntryIndices(ctx sdk.Context) []string
GetAllEntryIndices returns all Entry indices
func (FixationStore) GetAllEntryIndicesWithPrefix ¶
func (fs FixationStore) GetAllEntryIndicesWithPrefix(ctx sdk.Context, prefix string) []string
GetAllEntryIndicesWithPrefix returns all Entry indices with a given prefix
func (*FixationStore) GetAllEntryVersions ¶
func (fs *FixationStore) GetAllEntryVersions(ctx sdk.Context, index string) (blocks []uint64)
GetAllEntryVersions returns a list of all versions (blocks) of an entry, for use in testing and migrations (includes stale and deleted entry versions).
func (*FixationStore) GetEntry ¶
func (fs *FixationStore) GetEntry(ctx sdk.Context, index string, entryData codec.ProtoMarshaler) bool
GetEntry returns the latest entry by index and increments the refcount (while ignoring entries in stale-period)
func (*FixationStore) GetEntryVersionsRange ¶
func (fs *FixationStore) GetEntryVersionsRange(ctx sdk.Context, index string, block, delta uint64) (blocks []uint64)
GetEntryVersionsRange returns a list of versions from nearest-no-later block and onward, and not more than delta blocks further (skip stale entries).
func (*FixationStore) GetStoreKey ¶
func (fs *FixationStore) GetStoreKey() storetypes.StoreKey
func (*FixationStore) GetStorePrefix ¶
func (fs *FixationStore) GetStorePrefix() string
func (*FixationStore) HasEntry ¶
HasEntry returns true if an entry version exists for the given index, block tuple (any kind of entry, even deleted or stale).
func (*FixationStore) Init ¶
func (fs *FixationStore) Init(ctx sdk.Context, gs GenesisState)
func (*FixationStore) IsEntryStale ¶
IsEntryStale returns true if an entry version exists and is stale.
func (*FixationStore) ModifyEntry ¶
func (fs *FixationStore) ModifyEntry(ctx sdk.Context, index string, block uint64, entryData codec.ProtoMarshaler)
ModifyEntry modifies an existing entry in the store (should be called only for existing entries; will panic otherwise)
func (*FixationStore) PutEntry ¶
func (fs *FixationStore) PutEntry(ctx sdk.Context, index string, block uint64)
PutEntry finds the entry by index and block and decrements the refcount (should be called only for existing entries; will panic otherwise)
func (*FixationStore) ReadEntry ¶
func (fs *FixationStore) ReadEntry(ctx sdk.Context, index string, block uint64, entryData codec.ProtoMarshaler)
ReadEntry returns and existing entry with index and specific block (should be called only for existing entries; will panic otherwise)
type GenesisEntries ¶
type GenesisEntries struct { Index string `protobuf:"bytes,1,opt,name=index,proto3" json:"index,omitempty"` IsLive bool `protobuf:"varint,2,opt,name=is_live,json=isLive,proto3" json:"is_live,omitempty"` Entries []Entry `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries"` }
func (*GenesisEntries) Descriptor ¶
func (*GenesisEntries) Descriptor() ([]byte, []int)
func (*GenesisEntries) GetEntries ¶
func (m *GenesisEntries) GetEntries() []Entry
func (*GenesisEntries) GetIndex ¶
func (m *GenesisEntries) GetIndex() string
func (*GenesisEntries) GetIsLive ¶
func (m *GenesisEntries) GetIsLive() bool
func (*GenesisEntries) Marshal ¶
func (m *GenesisEntries) Marshal() (dAtA []byte, err error)
func (*GenesisEntries) MarshalToSizedBuffer ¶
func (m *GenesisEntries) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisEntries) ProtoMessage ¶
func (*GenesisEntries) ProtoMessage()
func (*GenesisEntries) Reset ¶
func (m *GenesisEntries) Reset()
func (*GenesisEntries) Size ¶
func (m *GenesisEntries) Size() (n int)
func (*GenesisEntries) String ¶
func (m *GenesisEntries) String() string
func (*GenesisEntries) Unmarshal ¶
func (m *GenesisEntries) Unmarshal(dAtA []byte) error
func (*GenesisEntries) XXX_DiscardUnknown ¶
func (m *GenesisEntries) XXX_DiscardUnknown()
func (*GenesisEntries) XXX_Marshal ¶
func (m *GenesisEntries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisEntries) XXX_Merge ¶
func (m *GenesisEntries) XXX_Merge(src proto.Message)
func (*GenesisEntries) XXX_Size ¶
func (m *GenesisEntries) XXX_Size() int
func (*GenesisEntries) XXX_Unmarshal ¶
func (m *GenesisEntries) XXX_Unmarshal(b []byte) error
type GenesisState ¶
type GenesisState struct { Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` Entries []GenesisEntries `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries"` Timerstore types.GenesisState `protobuf:"bytes,3,opt,name=timerstore,proto3" json:"timerstore"` }
func DefaultGenesis ¶
func DefaultGenesis() *GenesisState
func (*GenesisState) Descriptor ¶
func (*GenesisState) Descriptor() ([]byte, []int)
func (*GenesisState) GetEntries ¶
func (m *GenesisState) GetEntries() []GenesisEntries
func (*GenesisState) GetTimerstore ¶
func (m *GenesisState) GetTimerstore() types.GenesisState
func (*GenesisState) GetVersion ¶
func (m *GenesisState) GetVersion() uint64
func (*GenesisState) Marshal ¶
func (m *GenesisState) Marshal() (dAtA []byte, err error)
func (*GenesisState) MarshalToSizedBuffer ¶
func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GenesisState) ProtoMessage ¶
func (*GenesisState) ProtoMessage()
func (*GenesisState) Reset ¶
func (m *GenesisState) Reset()
func (*GenesisState) Size ¶
func (m *GenesisState) Size() (n int)
func (*GenesisState) String ¶
func (m *GenesisState) String() string
func (*GenesisState) Unmarshal ¶
func (m *GenesisState) Unmarshal(dAtA []byte) error
func (*GenesisState) XXX_DiscardUnknown ¶
func (m *GenesisState) XXX_DiscardUnknown()
func (*GenesisState) XXX_Marshal ¶
func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GenesisState) XXX_Merge ¶
func (m *GenesisState) XXX_Merge(src proto.Message)
func (*GenesisState) XXX_Size ¶
func (m *GenesisState) XXX_Size() int
func (*GenesisState) XXX_Unmarshal ¶
func (m *GenesisState) XXX_Unmarshal(b []byte) error
type GetStaleBlocks ¶
type QueryAllIndicesRequest ¶
type QueryAllIndicesRequest struct { StoreKey string `protobuf:"bytes,1,opt,name=store_key,json=storeKey,proto3" json:"store_key,omitempty"` Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"` }
func (*QueryAllIndicesRequest) Descriptor ¶
func (*QueryAllIndicesRequest) Descriptor() ([]byte, []int)
func (*QueryAllIndicesRequest) GetPrefix ¶
func (m *QueryAllIndicesRequest) GetPrefix() string
func (*QueryAllIndicesRequest) GetStoreKey ¶
func (m *QueryAllIndicesRequest) GetStoreKey() string
func (*QueryAllIndicesRequest) Marshal ¶
func (m *QueryAllIndicesRequest) Marshal() (dAtA []byte, err error)
func (*QueryAllIndicesRequest) MarshalTo ¶
func (m *QueryAllIndicesRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryAllIndicesRequest) MarshalToSizedBuffer ¶
func (m *QueryAllIndicesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryAllIndicesRequest) ProtoMessage ¶
func (*QueryAllIndicesRequest) ProtoMessage()
func (*QueryAllIndicesRequest) Reset ¶
func (m *QueryAllIndicesRequest) Reset()
func (*QueryAllIndicesRequest) Size ¶
func (m *QueryAllIndicesRequest) Size() (n int)
func (*QueryAllIndicesRequest) String ¶
func (m *QueryAllIndicesRequest) String() string
func (*QueryAllIndicesRequest) Unmarshal ¶
func (m *QueryAllIndicesRequest) Unmarshal(dAtA []byte) error
func (*QueryAllIndicesRequest) XXX_DiscardUnknown ¶
func (m *QueryAllIndicesRequest) XXX_DiscardUnknown()
func (*QueryAllIndicesRequest) XXX_Marshal ¶
func (m *QueryAllIndicesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryAllIndicesRequest) XXX_Merge ¶
func (m *QueryAllIndicesRequest) XXX_Merge(src proto.Message)
func (*QueryAllIndicesRequest) XXX_Size ¶
func (m *QueryAllIndicesRequest) XXX_Size() int
func (*QueryAllIndicesRequest) XXX_Unmarshal ¶
func (m *QueryAllIndicesRequest) XXX_Unmarshal(b []byte) error
type QueryAllIndicesResponse ¶
type QueryAllIndicesResponse struct {
Indices []string `protobuf:"bytes,1,rep,name=indices,proto3" json:"indices,omitempty"`
}
func (*QueryAllIndicesResponse) Descriptor ¶
func (*QueryAllIndicesResponse) Descriptor() ([]byte, []int)
func (*QueryAllIndicesResponse) GetIndices ¶
func (m *QueryAllIndicesResponse) GetIndices() []string
func (*QueryAllIndicesResponse) Marshal ¶
func (m *QueryAllIndicesResponse) Marshal() (dAtA []byte, err error)
func (*QueryAllIndicesResponse) MarshalTo ¶
func (m *QueryAllIndicesResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryAllIndicesResponse) MarshalToSizedBuffer ¶
func (m *QueryAllIndicesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryAllIndicesResponse) ProtoMessage ¶
func (*QueryAllIndicesResponse) ProtoMessage()
func (*QueryAllIndicesResponse) Reset ¶
func (m *QueryAllIndicesResponse) Reset()
func (*QueryAllIndicesResponse) Size ¶
func (m *QueryAllIndicesResponse) Size() (n int)
func (*QueryAllIndicesResponse) String ¶
func (m *QueryAllIndicesResponse) String() string
func (*QueryAllIndicesResponse) Unmarshal ¶
func (m *QueryAllIndicesResponse) Unmarshal(dAtA []byte) error
func (*QueryAllIndicesResponse) XXX_DiscardUnknown ¶
func (m *QueryAllIndicesResponse) XXX_DiscardUnknown()
func (*QueryAllIndicesResponse) XXX_Marshal ¶
func (m *QueryAllIndicesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryAllIndicesResponse) XXX_Merge ¶
func (m *QueryAllIndicesResponse) XXX_Merge(src proto.Message)
func (*QueryAllIndicesResponse) XXX_Size ¶
func (m *QueryAllIndicesResponse) XXX_Size() int
func (*QueryAllIndicesResponse) XXX_Unmarshal ¶
func (m *QueryAllIndicesResponse) XXX_Unmarshal(b []byte) error
type QueryClient ¶
type QueryClient interface { // Queries a fixation store for all its indices. AllIndices(ctx context.Context, in *QueryAllIndicesRequest, opts ...grpc.CallOption) (*QueryAllIndicesResponse, error) // Queries for all store keys. StoreKeys(ctx context.Context, in *QueryStoreKeysRequest, opts ...grpc.CallOption) (*QueryStoreKeysResponse, error) // Queries for all versions of a specific entry (versions = different blocks). Versions(ctx context.Context, in *QueryVersionsRequest, opts ...grpc.CallOption) (*QueryVersionsResponse, error) // Queries for a specific entry with detailed information. Entry(ctx context.Context, in *QueryEntryRequest, opts ...grpc.CallOption) (*QueryEntryResponse, error) }
QueryClient is the client API for Query service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewQueryClient ¶
func NewQueryClient(cc grpc1.ClientConn) QueryClient
type QueryEntryRequest ¶
type QueryEntryRequest struct { StoreKey string `protobuf:"bytes,1,opt,name=store_key,json=storeKey,proto3" json:"store_key,omitempty"` Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"` Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` Block uint64 `protobuf:"varint,4,opt,name=block,proto3" json:"block,omitempty"` HideData bool `protobuf:"varint,5,opt,name=hide_data,json=hideData,proto3" json:"hide_data,omitempty"` StringData bool `protobuf:"varint,6,opt,name=string_data,json=stringData,proto3" json:"string_data,omitempty"` }
func (*QueryEntryRequest) Descriptor ¶
func (*QueryEntryRequest) Descriptor() ([]byte, []int)
func (*QueryEntryRequest) GetBlock ¶
func (m *QueryEntryRequest) GetBlock() uint64
func (*QueryEntryRequest) GetHideData ¶
func (m *QueryEntryRequest) GetHideData() bool
func (*QueryEntryRequest) GetKey ¶
func (m *QueryEntryRequest) GetKey() string
func (*QueryEntryRequest) GetPrefix ¶
func (m *QueryEntryRequest) GetPrefix() string
func (*QueryEntryRequest) GetStoreKey ¶
func (m *QueryEntryRequest) GetStoreKey() string
func (*QueryEntryRequest) GetStringData ¶
func (m *QueryEntryRequest) GetStringData() bool
func (*QueryEntryRequest) Marshal ¶
func (m *QueryEntryRequest) Marshal() (dAtA []byte, err error)
func (*QueryEntryRequest) MarshalTo ¶
func (m *QueryEntryRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryEntryRequest) MarshalToSizedBuffer ¶
func (m *QueryEntryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryEntryRequest) ProtoMessage ¶
func (*QueryEntryRequest) ProtoMessage()
func (*QueryEntryRequest) Reset ¶
func (m *QueryEntryRequest) Reset()
func (*QueryEntryRequest) Size ¶
func (m *QueryEntryRequest) Size() (n int)
func (*QueryEntryRequest) String ¶
func (m *QueryEntryRequest) String() string
func (*QueryEntryRequest) Unmarshal ¶
func (m *QueryEntryRequest) Unmarshal(dAtA []byte) error
func (*QueryEntryRequest) XXX_DiscardUnknown ¶
func (m *QueryEntryRequest) XXX_DiscardUnknown()
func (*QueryEntryRequest) XXX_Marshal ¶
func (m *QueryEntryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryEntryRequest) XXX_Merge ¶
func (m *QueryEntryRequest) XXX_Merge(src proto.Message)
func (*QueryEntryRequest) XXX_Size ¶
func (m *QueryEntryRequest) XXX_Size() int
func (*QueryEntryRequest) XXX_Unmarshal ¶
func (m *QueryEntryRequest) XXX_Unmarshal(b []byte) error
type QueryEntryResponse ¶
type QueryEntryResponse struct { Entry *Entry `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"` StringData string `protobuf:"bytes,2,opt,name=string_data,json=stringData,proto3" json:"string_data,omitempty"` }
func (*QueryEntryResponse) Descriptor ¶
func (*QueryEntryResponse) Descriptor() ([]byte, []int)
func (*QueryEntryResponse) GetEntry ¶
func (m *QueryEntryResponse) GetEntry() *Entry
func (*QueryEntryResponse) GetStringData ¶
func (m *QueryEntryResponse) GetStringData() string
func (*QueryEntryResponse) Marshal ¶
func (m *QueryEntryResponse) Marshal() (dAtA []byte, err error)
func (*QueryEntryResponse) MarshalTo ¶
func (m *QueryEntryResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryEntryResponse) MarshalToSizedBuffer ¶
func (m *QueryEntryResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryEntryResponse) ProtoMessage ¶
func (*QueryEntryResponse) ProtoMessage()
func (*QueryEntryResponse) Reset ¶
func (m *QueryEntryResponse) Reset()
func (*QueryEntryResponse) Size ¶
func (m *QueryEntryResponse) Size() (n int)
func (*QueryEntryResponse) String ¶
func (m *QueryEntryResponse) String() string
func (*QueryEntryResponse) Unmarshal ¶
func (m *QueryEntryResponse) Unmarshal(dAtA []byte) error
func (*QueryEntryResponse) XXX_DiscardUnknown ¶
func (m *QueryEntryResponse) XXX_DiscardUnknown()
func (*QueryEntryResponse) XXX_Marshal ¶
func (m *QueryEntryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryEntryResponse) XXX_Merge ¶
func (m *QueryEntryResponse) XXX_Merge(src proto.Message)
func (*QueryEntryResponse) XXX_Size ¶
func (m *QueryEntryResponse) XXX_Size() int
func (*QueryEntryResponse) XXX_Unmarshal ¶
func (m *QueryEntryResponse) XXX_Unmarshal(b []byte) error
type QueryServer ¶
type QueryServer interface { // Queries a fixation store for all its indices. AllIndices(context.Context, *QueryAllIndicesRequest) (*QueryAllIndicesResponse, error) // Queries for all store keys. StoreKeys(context.Context, *QueryStoreKeysRequest) (*QueryStoreKeysResponse, error) // Queries for all versions of a specific entry (versions = different blocks). Versions(context.Context, *QueryVersionsRequest) (*QueryVersionsResponse, error) // Queries for a specific entry with detailed information. Entry(context.Context, *QueryEntryRequest) (*QueryEntryResponse, error) }
QueryServer is the server API for Query service.
type QueryStoreKeysRequest ¶
type QueryStoreKeysRequest struct { }
func (*QueryStoreKeysRequest) Descriptor ¶
func (*QueryStoreKeysRequest) Descriptor() ([]byte, []int)
func (*QueryStoreKeysRequest) Marshal ¶
func (m *QueryStoreKeysRequest) Marshal() (dAtA []byte, err error)
func (*QueryStoreKeysRequest) MarshalTo ¶
func (m *QueryStoreKeysRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryStoreKeysRequest) MarshalToSizedBuffer ¶
func (m *QueryStoreKeysRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryStoreKeysRequest) ProtoMessage ¶
func (*QueryStoreKeysRequest) ProtoMessage()
func (*QueryStoreKeysRequest) Reset ¶
func (m *QueryStoreKeysRequest) Reset()
func (*QueryStoreKeysRequest) Size ¶
func (m *QueryStoreKeysRequest) Size() (n int)
func (*QueryStoreKeysRequest) String ¶
func (m *QueryStoreKeysRequest) String() string
func (*QueryStoreKeysRequest) Unmarshal ¶
func (m *QueryStoreKeysRequest) Unmarshal(dAtA []byte) error
func (*QueryStoreKeysRequest) XXX_DiscardUnknown ¶
func (m *QueryStoreKeysRequest) XXX_DiscardUnknown()
func (*QueryStoreKeysRequest) XXX_Marshal ¶
func (m *QueryStoreKeysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryStoreKeysRequest) XXX_Merge ¶
func (m *QueryStoreKeysRequest) XXX_Merge(src proto.Message)
func (*QueryStoreKeysRequest) XXX_Size ¶
func (m *QueryStoreKeysRequest) XXX_Size() int
func (*QueryStoreKeysRequest) XXX_Unmarshal ¶
func (m *QueryStoreKeysRequest) XXX_Unmarshal(b []byte) error
type QueryStoreKeysResponse ¶
type QueryStoreKeysResponse struct {
Keys []StoreKeyAndPrefix `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys"`
}
func (*QueryStoreKeysResponse) Descriptor ¶
func (*QueryStoreKeysResponse) Descriptor() ([]byte, []int)
func (*QueryStoreKeysResponse) GetKeys ¶
func (m *QueryStoreKeysResponse) GetKeys() []StoreKeyAndPrefix
func (*QueryStoreKeysResponse) Marshal ¶
func (m *QueryStoreKeysResponse) Marshal() (dAtA []byte, err error)
func (*QueryStoreKeysResponse) MarshalTo ¶
func (m *QueryStoreKeysResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryStoreKeysResponse) MarshalToSizedBuffer ¶
func (m *QueryStoreKeysResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryStoreKeysResponse) ProtoMessage ¶
func (*QueryStoreKeysResponse) ProtoMessage()
func (*QueryStoreKeysResponse) Reset ¶
func (m *QueryStoreKeysResponse) Reset()
func (*QueryStoreKeysResponse) Size ¶
func (m *QueryStoreKeysResponse) Size() (n int)
func (*QueryStoreKeysResponse) String ¶
func (m *QueryStoreKeysResponse) String() string
func (*QueryStoreKeysResponse) Unmarshal ¶
func (m *QueryStoreKeysResponse) Unmarshal(dAtA []byte) error
func (*QueryStoreKeysResponse) XXX_DiscardUnknown ¶
func (m *QueryStoreKeysResponse) XXX_DiscardUnknown()
func (*QueryStoreKeysResponse) XXX_Marshal ¶
func (m *QueryStoreKeysResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryStoreKeysResponse) XXX_Merge ¶
func (m *QueryStoreKeysResponse) XXX_Merge(src proto.Message)
func (*QueryStoreKeysResponse) XXX_Size ¶
func (m *QueryStoreKeysResponse) XXX_Size() int
func (*QueryStoreKeysResponse) XXX_Unmarshal ¶
func (m *QueryStoreKeysResponse) XXX_Unmarshal(b []byte) error
type QueryVersionsRequest ¶
type QueryVersionsRequest struct { StoreKey string `protobuf:"bytes,1,opt,name=store_key,json=storeKey,proto3" json:"store_key,omitempty"` Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"` Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` }
func (*QueryVersionsRequest) Descriptor ¶
func (*QueryVersionsRequest) Descriptor() ([]byte, []int)
func (*QueryVersionsRequest) GetKey ¶
func (m *QueryVersionsRequest) GetKey() string
func (*QueryVersionsRequest) GetPrefix ¶
func (m *QueryVersionsRequest) GetPrefix() string
func (*QueryVersionsRequest) GetStoreKey ¶
func (m *QueryVersionsRequest) GetStoreKey() string
func (*QueryVersionsRequest) Marshal ¶
func (m *QueryVersionsRequest) Marshal() (dAtA []byte, err error)
func (*QueryVersionsRequest) MarshalTo ¶
func (m *QueryVersionsRequest) MarshalTo(dAtA []byte) (int, error)
func (*QueryVersionsRequest) MarshalToSizedBuffer ¶
func (m *QueryVersionsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryVersionsRequest) ProtoMessage ¶
func (*QueryVersionsRequest) ProtoMessage()
func (*QueryVersionsRequest) Reset ¶
func (m *QueryVersionsRequest) Reset()
func (*QueryVersionsRequest) Size ¶
func (m *QueryVersionsRequest) Size() (n int)
func (*QueryVersionsRequest) String ¶
func (m *QueryVersionsRequest) String() string
func (*QueryVersionsRequest) Unmarshal ¶
func (m *QueryVersionsRequest) Unmarshal(dAtA []byte) error
func (*QueryVersionsRequest) XXX_DiscardUnknown ¶
func (m *QueryVersionsRequest) XXX_DiscardUnknown()
func (*QueryVersionsRequest) XXX_Marshal ¶
func (m *QueryVersionsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryVersionsRequest) XXX_Merge ¶
func (m *QueryVersionsRequest) XXX_Merge(src proto.Message)
func (*QueryVersionsRequest) XXX_Size ¶
func (m *QueryVersionsRequest) XXX_Size() int
func (*QueryVersionsRequest) XXX_Unmarshal ¶
func (m *QueryVersionsRequest) XXX_Unmarshal(b []byte) error
type QueryVersionsResponse ¶
type QueryVersionsResponse struct {
Entries []Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries"`
}
func (*QueryVersionsResponse) Descriptor ¶
func (*QueryVersionsResponse) Descriptor() ([]byte, []int)
func (*QueryVersionsResponse) GetEntries ¶
func (m *QueryVersionsResponse) GetEntries() []Entry
func (*QueryVersionsResponse) Marshal ¶
func (m *QueryVersionsResponse) Marshal() (dAtA []byte, err error)
func (*QueryVersionsResponse) MarshalTo ¶
func (m *QueryVersionsResponse) MarshalTo(dAtA []byte) (int, error)
func (*QueryVersionsResponse) MarshalToSizedBuffer ¶
func (m *QueryVersionsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*QueryVersionsResponse) ProtoMessage ¶
func (*QueryVersionsResponse) ProtoMessage()
func (*QueryVersionsResponse) Reset ¶
func (m *QueryVersionsResponse) Reset()
func (*QueryVersionsResponse) Size ¶
func (m *QueryVersionsResponse) Size() (n int)
func (*QueryVersionsResponse) String ¶
func (m *QueryVersionsResponse) String() string
func (*QueryVersionsResponse) Unmarshal ¶
func (m *QueryVersionsResponse) Unmarshal(dAtA []byte) error
func (*QueryVersionsResponse) XXX_DiscardUnknown ¶
func (m *QueryVersionsResponse) XXX_DiscardUnknown()
func (*QueryVersionsResponse) XXX_Marshal ¶
func (m *QueryVersionsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*QueryVersionsResponse) XXX_Merge ¶
func (m *QueryVersionsResponse) XXX_Merge(src proto.Message)
func (*QueryVersionsResponse) XXX_Size ¶
func (m *QueryVersionsResponse) XXX_Size() int
func (*QueryVersionsResponse) XXX_Unmarshal ¶
func (m *QueryVersionsResponse) XXX_Unmarshal(b []byte) error
type SafeIndex ¶
type SafeIndex string
SafeIndex is a sanitized string, i.e. contains only visible ascii characters (i.e. Ascii 32-126), and terminates with (ascii) DEL; this ensures that an index can never be a prefix of another index.
func SanitizeIndex ¶
sanitizeIndex checks that a string contains only visible ascii characters (i.e. Ascii 32-126), and appends a (ascii) DEL to the index; this ensures that an index can never be a prefix of another index.
type StoreKeyAndPrefix ¶
type StoreKeyAndPrefix struct { StoreKey string `protobuf:"bytes,1,opt,name=store_key,json=storeKey,proto3" json:"store_key,omitempty"` Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"` }
func (*StoreKeyAndPrefix) Descriptor ¶
func (*StoreKeyAndPrefix) Descriptor() ([]byte, []int)
func (*StoreKeyAndPrefix) GetPrefix ¶
func (m *StoreKeyAndPrefix) GetPrefix() string
func (*StoreKeyAndPrefix) GetStoreKey ¶
func (m *StoreKeyAndPrefix) GetStoreKey() string
func (*StoreKeyAndPrefix) Marshal ¶
func (m *StoreKeyAndPrefix) Marshal() (dAtA []byte, err error)
func (*StoreKeyAndPrefix) MarshalTo ¶
func (m *StoreKeyAndPrefix) MarshalTo(dAtA []byte) (int, error)
func (*StoreKeyAndPrefix) MarshalToSizedBuffer ¶
func (m *StoreKeyAndPrefix) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StoreKeyAndPrefix) ProtoMessage ¶
func (*StoreKeyAndPrefix) ProtoMessage()
func (*StoreKeyAndPrefix) Reset ¶
func (m *StoreKeyAndPrefix) Reset()
func (*StoreKeyAndPrefix) Size ¶
func (m *StoreKeyAndPrefix) Size() (n int)
func (*StoreKeyAndPrefix) String ¶
func (m *StoreKeyAndPrefix) String() string
func (*StoreKeyAndPrefix) Unmarshal ¶
func (m *StoreKeyAndPrefix) Unmarshal(dAtA []byte) error
func (*StoreKeyAndPrefix) XXX_DiscardUnknown ¶
func (m *StoreKeyAndPrefix) XXX_DiscardUnknown()
func (*StoreKeyAndPrefix) XXX_Marshal ¶
func (m *StoreKeyAndPrefix) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StoreKeyAndPrefix) XXX_Merge ¶
func (m *StoreKeyAndPrefix) XXX_Merge(src proto.Message)
func (*StoreKeyAndPrefix) XXX_Size ¶
func (m *StoreKeyAndPrefix) XXX_Size() int
func (*StoreKeyAndPrefix) XXX_Unmarshal ¶
func (m *StoreKeyAndPrefix) XXX_Unmarshal(b []byte) error
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer can be embedded to have forward compatible implementations.
func (*UnimplementedQueryServer) AllIndices ¶
func (*UnimplementedQueryServer) AllIndices(ctx context.Context, req *QueryAllIndicesRequest) (*QueryAllIndicesResponse, error)
func (*UnimplementedQueryServer) Entry ¶
func (*UnimplementedQueryServer) Entry(ctx context.Context, req *QueryEntryRequest) (*QueryEntryResponse, error)
func (*UnimplementedQueryServer) StoreKeys ¶
func (*UnimplementedQueryServer) StoreKeys(ctx context.Context, req *QueryStoreKeysRequest) (*QueryStoreKeysResponse, error)
func (*UnimplementedQueryServer) Versions ¶
func (*UnimplementedQueryServer) Versions(ctx context.Context, req *QueryVersionsRequest) (*QueryVersionsResponse, error)