models

package
v0.0.0-...-999fc6a Latest Latest
Warning

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

 Go to latest Published: Feb 13, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DEFAULT            = "DEFAULT"
	SKIP_ON_DUPLICATE  = "SKIP_ON_DUPLICATE"
	ERROR_ON_DUPLICATE = "ERROR_ON_DUPLICATE"
	ALL_OR_NONE        = "ALL_OR_NONE"
)

Constant values for operation strategies

View Source 
const (
	PageSizeZero    int64 = 0
	PageSizeNano    int64 = 1024 * 1024 * 4
	PageSizeMicro   int64 = PageSizeNano * 4
	PageSizeSmall   int64 = PageSizeMicro * 8
	PageSizeMedium  int64 = PageSizeSmall * 10
	PageSizeLarge   int64 = PageSizeMedium * 12
	PageSizeXLarge  int64 = PageSizeLarge * 14
	PageSize2XLarge int64 = PageSizeXLarge * 16
)

Variables

View Source 
var EmptyPage = &Page{}

EmptyPage is the default empty page

View Source 
var File_models_proto protoreflect.FileDescriptor

Functions

func GetMaxPageSize 

func GetMaxPageSize(tier int32) int64

GetMaxPageSize returns the maximum page size for the given storage tier

func GetMinPageSize 

func GetMinPageSize(tier int32) int64

GetMinPageSize returns the minimum page size for the given storage tier

func NewConcurrencyError 

func NewConcurrencyError(message string) error

NewConcurrencyError is a constructor function for creating a new ConcurrencyError.

Types

type ConcurrencyError 

type ConcurrencyError struct {
	Message string
}

ConcurrencyError represents an error related to concurrency issues.

func (*ConcurrencyError) Error 

func (e *ConcurrencyError) Error() string

Error implements the error interface for ConcurrencyError.

type ConcurrencyTag 

type ConcurrencyTag interface{}

type ConsumePartitionArgs 

type ConsumePartitionArgs struct {

	// The unique identifier of the space containing the partition
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition to consume from
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// The minimum sequence number to start consuming from (exclusive)
	MinSequence uint64 `protobuf:"varint,3,opt,name=min_sequence,json=minSequence,proto3" json:"min_sequence,omitempty"`
	// The minimum timestamp to include in consumption (in milliseconds since epoch)
	MinTimestamp int64 `protobuf:"varint,4,opt,name=min_timestamp,json=minTimestamp,proto3" json:"min_timestamp,omitempty"`
	// The maximum sequence number to include in consumption (inclusive)
	MaxSequence uint64 `protobuf:"varint,5,opt,name=max_sequence,json=maxSequence,proto3" json:"max_sequence,omitempty"`
	// The maximum timestamp to include in consumption (in milliseconds since epoch)
	MaxTimestamp int64 `protobuf:"varint,6,opt,name=max_timestamp,json=maxTimestamp,proto3" json:"max_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumePartitionArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use ConsumePartitionArgs.ProtoReflect.Descriptor instead.

func (*ConsumePartitionArgs) GetMaxSequence added in v0.0.6 

func (x *ConsumePartitionArgs) GetMaxSequence() uint64

func (*ConsumePartitionArgs) GetMaxTimestamp added in v0.0.6 

func (x *ConsumePartitionArgs) GetMaxTimestamp() int64

func (*ConsumePartitionArgs) GetMinSequence added in v0.0.6 

func (x *ConsumePartitionArgs) GetMinSequence() uint64

func (*ConsumePartitionArgs) GetMinTimestamp added in v0.0.6 

func (x *ConsumePartitionArgs) GetMinTimestamp() int64

func (*ConsumePartitionArgs) GetPartition added in v0.0.6 

func (x *ConsumePartitionArgs) GetPartition() string

func (*ConsumePartitionArgs) GetSpace added in v0.0.6 

func (x *ConsumePartitionArgs) GetSpace() string

func (*ConsumePartitionArgs) ProtoMessage added in v0.0.6 

func (*ConsumePartitionArgs) ProtoMessage()

func (*ConsumePartitionArgs) ProtoReflect added in v0.0.6 

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

func (*ConsumePartitionArgs) Reset added in v0.0.6 

func (x *ConsumePartitionArgs) Reset()

func (*ConsumePartitionArgs) String added in v0.0.6 

func (x *ConsumePartitionArgs) String() string

type ConsumePartitionRequest 

type ConsumePartitionRequest struct {

	// The partition to consume
	Partition string `protobuf:"bytes,1,opt,name=partition,proto3" json:"partition,omitempty"`
	// The minimum sequence exclusive (optional)
	MinSequence uint64 `protobuf:"varint,2,opt,name=min_sequence,json=minSequence,proto3" json:"min_sequence,omitempty"`
	// The minimum timestamp inclusive (optional)
	MinTimestamp int64 `protobuf:"varint,3,opt,name=min_timestamp,json=minTimestamp,proto3" json:"min_timestamp,omitempty"`
	// The maximum sequence inclusive (optional)
	MaxSequence uint64 `protobuf:"varint,4,opt,name=max_sequence,json=maxSequence,proto3" json:"max_sequence,omitempty"`
	// The maximum timestamp inclusive (optional)
	MaxTimestamp int64 `protobuf:"varint,5,opt,name=max_timestamp,json=maxTimestamp,proto3" json:"max_timestamp,omitempty"`
	// contains filtered or unexported fields
}

Request to consume entries from a partition

func (*ConsumePartitionRequest) Descriptor deprecated 

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

Deprecated: Use ConsumePartitionRequest.ProtoReflect.Descriptor instead.

func (*ConsumePartitionRequest) GetMaxSequence 

func (x *ConsumePartitionRequest) GetMaxSequence() uint64

func (*ConsumePartitionRequest) GetMaxTimestamp 

func (x *ConsumePartitionRequest) GetMaxTimestamp() int64

func (*ConsumePartitionRequest) GetMinSequence 

func (x *ConsumePartitionRequest) GetMinSequence() uint64

func (*ConsumePartitionRequest) GetMinTimestamp 

func (x *ConsumePartitionRequest) GetMinTimestamp() int64

func (*ConsumePartitionRequest) GetPartition 

func (x *ConsumePartitionRequest) GetPartition() string

func (*ConsumePartitionRequest) ProtoMessage 

func (*ConsumePartitionRequest) ProtoMessage()

func (*ConsumePartitionRequest) ProtoReflect 

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

func (*ConsumePartitionRequest) Reset 

func (x *ConsumePartitionRequest) Reset()

func (*ConsumePartitionRequest) String 

func (x *ConsumePartitionRequest) String() string

type ConsumeSpaceArgs 

type ConsumeSpaceArgs struct {

	// The unique identifier of the space to consume from
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The minimum timestamp to include in consumption (in milliseconds since epoch)
	MinTimestamp int64 `protobuf:"varint,2,opt,name=min_timestamp,json=minTimestamp,proto3" json:"min_timestamp,omitempty"`
	// The maximum timestamp to include in consumption (in milliseconds since epoch)
	MaxTimestamp int64 `protobuf:"varint,3,opt,name=max_timestamp,json=maxTimestamp,proto3" json:"max_timestamp,omitempty"`
	// Map of partition offsets to start consuming from
	Offsets map[string]*Offset `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConsumeSpaceArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use ConsumeSpaceArgs.ProtoReflect.Descriptor instead.

func (*ConsumeSpaceArgs) GetMaxTimestamp added in v0.0.6 

func (x *ConsumeSpaceArgs) GetMaxTimestamp() int64

func (*ConsumeSpaceArgs) GetMinTimestamp added in v0.0.6 

func (x *ConsumeSpaceArgs) GetMinTimestamp() int64

func (*ConsumeSpaceArgs) GetOffsets added in v0.0.6 

func (x *ConsumeSpaceArgs) GetOffsets() map[string]*Offset

func (*ConsumeSpaceArgs) GetSpace added in v0.0.6 

func (x *ConsumeSpaceArgs) GetSpace() string

func (*ConsumeSpaceArgs) ProtoMessage added in v0.0.6 

func (*ConsumeSpaceArgs) ProtoMessage()

func (*ConsumeSpaceArgs) ProtoReflect added in v0.0.6 

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

func (*ConsumeSpaceArgs) Reset added in v0.0.6 

func (x *ConsumeSpaceArgs) Reset()

func (*ConsumeSpaceArgs) String added in v0.0.6 

func (x *ConsumeSpaceArgs) String() string

type ConsumeSpaceRequest 

type ConsumeSpaceRequest struct {

	// Offsets for each stream in the space
	Offsets map[string]*Offset `` /* 141-byte string literal not displayed */
	// The minimum timestamp inclusive
	MinTimestamp int64 `protobuf:"varint,2,opt,name=min_timestamp,json=minTimestamp,proto3" json:"min_timestamp,omitempty"`
	// The maximum timestamp inclusive
	MaxTimestamp int64 `protobuf:"varint,4,opt,name=max_timestamp,json=maxTimestamp,proto3" json:"max_timestamp,omitempty"`
	// contains filtered or unexported fields
}

Request to consume entries from a space

func (*ConsumeSpaceRequest) Descriptor deprecated 

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

Deprecated: Use ConsumeSpaceRequest.ProtoReflect.Descriptor instead.

func (*ConsumeSpaceRequest) GetMaxTimestamp 

func (x *ConsumeSpaceRequest) GetMaxTimestamp() int64

func (*ConsumeSpaceRequest) GetMinTimestamp 

func (x *ConsumeSpaceRequest) GetMinTimestamp() int64

func (*ConsumeSpaceRequest) GetOffsets 

func (x *ConsumeSpaceRequest) GetOffsets() map[string]*Offset

func (*ConsumeSpaceRequest) ProtoMessage 

func (*ConsumeSpaceRequest) ProtoMessage()

func (*ConsumeSpaceRequest) ProtoReflect 

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

func (*ConsumeSpaceRequest) Reset 

func (x *ConsumeSpaceRequest) Reset()

func (*ConsumeSpaceRequest) String 

func (x *ConsumeSpaceRequest) String() string

type CoveringPages 

type CoveringPages struct {
	Pages   []TieredPage
	Covered bool
}

CoveringPages represents the result of a coverage calculation.

func GetCoveringPages 

func GetCoveringPages(pages []TieredPage, minSequence, maxSequence uint64) *CoveringPages

GetCoveringPages calculates the pages that cover the given sequence range.

type CreatePartitionArgs 

type CreatePartitionArgs struct {

	// The unique identifier of the space where the partition will be created
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier for the new partition
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePartitionArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use CreatePartitionArgs.ProtoReflect.Descriptor instead.

func (*CreatePartitionArgs) GetPartition added in v0.0.6 

func (x *CreatePartitionArgs) GetPartition() string

func (*CreatePartitionArgs) GetSpace added in v0.0.6 

func (x *CreatePartitionArgs) GetSpace() string

func (*CreatePartitionArgs) ProtoMessage added in v0.0.6 

func (*CreatePartitionArgs) ProtoMessage()

func (*CreatePartitionArgs) ProtoReflect added in v0.0.6 

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

func (*CreatePartitionArgs) Reset added in v0.0.6 

func (x *CreatePartitionArgs) Reset()

func (*CreatePartitionArgs) String added in v0.0.6 

func (x *CreatePartitionArgs) String() string

type CreatePartitionRequest 

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

Request to create a partition

func (*CreatePartitionRequest) Descriptor deprecated 

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

Deprecated: Use CreatePartitionRequest.ProtoReflect.Descriptor instead.

func (*CreatePartitionRequest) ProtoMessage 

func (*CreatePartitionRequest) ProtoMessage()

func (*CreatePartitionRequest) ProtoReflect 

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

func (*CreatePartitionRequest) Reset 

func (x *CreatePartitionRequest) Reset()

func (*CreatePartitionRequest) String 

func (x *CreatePartitionRequest) String() string

type CreateTierArgs 

type CreateTierArgs struct {

	// The unique identifier of the space containing the partition
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition where the tier will be created
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// The numerical level of the new tier (lower numbers indicate more recent data)
	Tier int32 `protobuf:"varint,3,opt,name=tier,proto3" json:"tier,omitempty"`
	// contains filtered or unexported fields
}

Arguments for tier operations

func (*CreateTierArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use CreateTierArgs.ProtoReflect.Descriptor instead.

func (*CreateTierArgs) GetPartition added in v0.0.6 

func (x *CreateTierArgs) GetPartition() string

func (*CreateTierArgs) GetSpace added in v0.0.6 

func (x *CreateTierArgs) GetSpace() string

func (*CreateTierArgs) GetTier added in v0.0.6 

func (x *CreateTierArgs) GetTier() int32

func (*CreateTierArgs) ProtoMessage added in v0.0.6 

func (*CreateTierArgs) ProtoMessage()

func (*CreateTierArgs) ProtoReflect added in v0.0.6 

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

func (*CreateTierArgs) Reset added in v0.0.6 

func (x *CreateTierArgs) Reset()

func (*CreateTierArgs) String added in v0.0.6 

func (x *CreateTierArgs) String() string

type DeletePageArgs 

type DeletePageArgs struct {

	// The unique identifier of the space containing the partition
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition containing the page
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// The numerical level of the tier containing the page
	Tier int32 `protobuf:"varint,3,opt,name=tier,proto3" json:"tier,omitempty"`
	// The sequential page number to delete
	Number int32 `protobuf:"varint,4,opt,name=number,proto3" json:"number,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletePageArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use DeletePageArgs.ProtoReflect.Descriptor instead.

func (*DeletePageArgs) GetNumber added in v0.0.6 

func (x *DeletePageArgs) GetNumber() int32

func (*DeletePageArgs) GetPartition added in v0.0.6 

func (x *DeletePageArgs) GetPartition() string

func (*DeletePageArgs) GetSpace added in v0.0.6 

func (x *DeletePageArgs) GetSpace() string

func (*DeletePageArgs) GetTier added in v0.0.6 

func (x *DeletePageArgs) GetTier() int32

func (*DeletePageArgs) ProtoMessage added in v0.0.6 

func (*DeletePageArgs) ProtoMessage()

func (*DeletePageArgs) ProtoReflect added in v0.0.6 

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

func (*DeletePageArgs) Reset added in v0.0.6 

func (x *DeletePageArgs) Reset()

func (*DeletePageArgs) String added in v0.0.6 

func (x *DeletePageArgs) String() string

type DeletePartitionArgs 

type DeletePartitionArgs struct {

	// The unique identifier of the space containing the partition
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition to delete
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletePartitionArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use DeletePartitionArgs.ProtoReflect.Descriptor instead.

func (*DeletePartitionArgs) GetPartition added in v0.0.6 

func (x *DeletePartitionArgs) GetPartition() string

func (*DeletePartitionArgs) GetSpace added in v0.0.6 

func (x *DeletePartitionArgs) GetSpace() string

func (*DeletePartitionArgs) ProtoMessage added in v0.0.6 

func (*DeletePartitionArgs) ProtoMessage()

func (*DeletePartitionArgs) ProtoReflect added in v0.0.6 

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

func (*DeletePartitionArgs) Reset added in v0.0.6 

func (x *DeletePartitionArgs) Reset()

func (*DeletePartitionArgs) String added in v0.0.6 

func (x *DeletePartitionArgs) String() string

type DeleteSpaceArgs 

type DeleteSpaceArgs struct {

	// The unique identifier of the space to delete
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSpaceArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use DeleteSpaceArgs.ProtoReflect.Descriptor instead.

func (*DeleteSpaceArgs) GetSpace added in v0.0.6 

func (x *DeleteSpaceArgs) GetSpace() string

func (*DeleteSpaceArgs) ProtoMessage added in v0.0.6 

func (*DeleteSpaceArgs) ProtoMessage()

func (*DeleteSpaceArgs) ProtoReflect added in v0.0.6 

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

func (*DeleteSpaceArgs) Reset added in v0.0.6 

func (x *DeleteSpaceArgs) Reset()

func (*DeleteSpaceArgs) String added in v0.0.6 

func (x *DeleteSpaceArgs) String() string

type Entry 

type Entry struct {

	// A monotonically increasing number that defines the order of entries
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// The timestamp when the entry was created (in milliseconds since epoch)
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// A unique identifier for this entry, used for deduplication (16 bytes)
	EntryId []byte `protobuf:"bytes,3,opt,name=entry_id,json=entryId,proto3" json:"entry_id,omitempty"`
	// An identifier linking related entries together (16 bytes)
	CorrelationId []byte `protobuf:"bytes,4,opt,name=correlation_id,json=correlationId,proto3" json:"correlation_id,omitempty"`
	// An identifier tracking the cause-and-effect relationship between entries (16 bytes)
	CausationId []byte `protobuf:"bytes,5,opt,name=causation_id,json=causationId,proto3" json:"causation_id,omitempty"`
	// The actual data content of the entry
	Payload []byte `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
	// Additional key-value pairs for storing custom metadata
	Metadata map[string]string `` /* 143-byte string literal not displayed */
	// contains filtered or unexported fields
}

A message representing an entry in the system

func (*Entry) Descriptor deprecated 

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

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

func (*Entry) GetCausationId 

func (x *Entry) GetCausationId() []byte

func (*Entry) GetCorrelationId 

func (x *Entry) GetCorrelationId() []byte

func (*Entry) GetEntryId 

func (x *Entry) GetEntryId() []byte

func (*Entry) GetMetadata 

func (x *Entry) GetMetadata() map[string]string

func (*Entry) GetOffset added in v0.0.8 

func (e *Entry) GetOffset() *Offset

func (*Entry) GetPayload 

func (x *Entry) GetPayload() []byte

func (*Entry) GetSequence 

func (x *Entry) GetSequence() uint64

func (*Entry) GetTimestamp 

func (x *Entry) GetTimestamp() int64

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect 

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

func (*Entry) Reset 

func (x *Entry) Reset()

func (*Entry) String 

func (x *Entry) String() string

type EntryEnvelope 

type EntryEnvelope struct {

	// The descriptor of the partition containing the entry
	PartitionDescriptor *PartitionDescriptor `protobuf:"bytes,1,opt,name=partition_descriptor,json=partitionDescriptor,proto3" json:"partition_descriptor,omitempty"`
	// The entry data
	Entry *Entry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
	// contains filtered or unexported fields
}

Envelope that includes a partition descriptor and an entry

func (*EntryEnvelope) Descriptor deprecated 

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

Deprecated: Use EntryEnvelope.ProtoReflect.Descriptor instead.

func (*EntryEnvelope) GetEntry 

func (x *EntryEnvelope) GetEntry() *Entry

func (*EntryEnvelope) GetOffset added in v0.0.8 

func (ee *EntryEnvelope) GetOffset() *Offset

func (*EntryEnvelope) GetPartitionDescriptor 

func (x *EntryEnvelope) GetPartitionDescriptor() *PartitionDescriptor

func (*EntryEnvelope) ProtoMessage 

func (*EntryEnvelope) ProtoMessage()

func (*EntryEnvelope) ProtoReflect 

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

func (*EntryEnvelope) Reset 

func (x *EntryEnvelope) Reset()

func (*EntryEnvelope) String 

func (x *EntryEnvelope) String() string

type GetPagesArgs 

type GetPagesArgs struct {

	// The unique identifier of the space containing the partition
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition to get pages from
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// The numerical level of the tier to get pages from
	Tier int32 `protobuf:"varint,3,opt,name=tier,proto3" json:"tier,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPagesArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use GetPagesArgs.ProtoReflect.Descriptor instead.

func (*GetPagesArgs) GetPartition added in v0.0.6 

func (x *GetPagesArgs) GetPartition() string

func (*GetPagesArgs) GetSpace added in v0.0.6 

func (x *GetPagesArgs) GetSpace() string

func (*GetPagesArgs) GetTier added in v0.0.6 

func (x *GetPagesArgs) GetTier() int32

func (*GetPagesArgs) ProtoMessage added in v0.0.6 

func (*GetPagesArgs) ProtoMessage()

func (*GetPagesArgs) ProtoReflect added in v0.0.6 

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

func (*GetPagesArgs) Reset added in v0.0.6 

func (x *GetPagesArgs) Reset()

func (*GetPagesArgs) String added in v0.0.6 

func (x *GetPagesArgs) String() string

type GetPartitionArgs 

type GetPartitionArgs struct {

	// The unique identifier of the space containing the partition
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition to retrieve
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPartitionArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use GetPartitionArgs.ProtoReflect.Descriptor instead.

func (*GetPartitionArgs) GetPartition added in v0.0.6 

func (x *GetPartitionArgs) GetPartition() string

func (*GetPartitionArgs) GetSpace added in v0.0.6 

func (x *GetPartitionArgs) GetSpace() string

func (*GetPartitionArgs) ProtoMessage added in v0.0.6 

func (*GetPartitionArgs) ProtoMessage()

func (*GetPartitionArgs) ProtoReflect added in v0.0.6 

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

func (*GetPartitionArgs) Reset added in v0.0.6 

func (x *GetPartitionArgs) Reset()

func (*GetPartitionArgs) String added in v0.0.6 

func (x *GetPartitionArgs) String() string

type GetPartitionsArgs 

type GetPartitionsArgs struct {

	// The unique identifier of the space containing the partitions
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The specific partition to retrieve (empty for all partitions)
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

Arguments for partition operations

func (*GetPartitionsArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use GetPartitionsArgs.ProtoReflect.Descriptor instead.

func (*GetPartitionsArgs) GetPartition added in v0.0.8 

func (x *GetPartitionsArgs) GetPartition() string

func (*GetPartitionsArgs) GetSpace added in v0.0.6 

func (x *GetPartitionsArgs) GetSpace() string

func (*GetPartitionsArgs) ProtoMessage added in v0.0.6 

func (*GetPartitionsArgs) ProtoMessage()

func (*GetPartitionsArgs) ProtoReflect added in v0.0.6 

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

func (*GetPartitionsArgs) Reset added in v0.0.6 

func (x *GetPartitionsArgs) Reset()

func (*GetPartitionsArgs) String added in v0.0.6 

func (x *GetPartitionsArgs) String() string

type GetPartitionsRequest 

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

Request to get partitions

func (*GetPartitionsRequest) Descriptor deprecated 

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

Deprecated: Use GetPartitionsRequest.ProtoReflect.Descriptor instead.

func (*GetPartitionsRequest) ProtoMessage 

func (*GetPartitionsRequest) ProtoMessage()

func (*GetPartitionsRequest) ProtoReflect 

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

func (*GetPartitionsRequest) Reset 

func (x *GetPartitionsRequest) Reset()

func (*GetPartitionsRequest) String 

func (x *GetPartitionsRequest) String() string

type GetSpacesArgs 

type GetSpacesArgs struct {

	// The unique identifier of the space to retrieve (empty for all spaces)
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// contains filtered or unexported fields
}

Arguments for space operations

func (*GetSpacesArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use GetSpacesArgs.ProtoReflect.Descriptor instead.

func (*GetSpacesArgs) GetSpace added in v0.0.8 

func (x *GetSpacesArgs) GetSpace() string

func (*GetSpacesArgs) ProtoMessage added in v0.0.6 

func (*GetSpacesArgs) ProtoMessage()

func (*GetSpacesArgs) ProtoReflect added in v0.0.6 

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

func (*GetSpacesArgs) Reset added in v0.0.6 

func (x *GetSpacesArgs) Reset()

func (*GetSpacesArgs) String added in v0.0.6 

func (x *GetSpacesArgs) String() string

type GetSpacesRequest 

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

Request to get spaces

func (*GetSpacesRequest) Descriptor deprecated 

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

Deprecated: Use GetSpacesRequest.ProtoReflect.Descriptor instead.

func (*GetSpacesRequest) ProtoMessage 

func (*GetSpacesRequest) ProtoMessage()

func (*GetSpacesRequest) ProtoReflect 

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

func (*GetSpacesRequest) Reset 

func (x *GetSpacesRequest) Reset()

func (*GetSpacesRequest) String 

func (x *GetSpacesRequest) String() string

type GetStatusArgs 

type GetStatusArgs struct {

	// The unique identifier of the space to check status for
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition to check status for
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

Arguments for status operations

func (*GetStatusArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use GetStatusArgs.ProtoReflect.Descriptor instead.

func (*GetStatusArgs) GetPartition added in v0.0.6 

func (x *GetStatusArgs) GetPartition() string

func (*GetStatusArgs) GetSpace added in v0.0.6 

func (x *GetStatusArgs) GetSpace() string

func (*GetStatusArgs) ProtoMessage added in v0.0.6 

func (*GetStatusArgs) ProtoMessage()

func (*GetStatusArgs) ProtoReflect added in v0.0.6 

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

func (*GetStatusArgs) Reset added in v0.0.6 

func (x *GetStatusArgs) Reset()

func (*GetStatusArgs) String added in v0.0.6 

func (x *GetStatusArgs) String() string

type GetStatusRequest 

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

Request to get the status

func (*GetStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetStatusRequest.ProtoReflect.Descriptor instead.

func (*GetStatusRequest) ProtoMessage 

func (*GetStatusRequest) ProtoMessage()

func (*GetStatusRequest) ProtoReflect 

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

func (*GetStatusRequest) Reset 

func (x *GetStatusRequest) Reset()

func (*GetStatusRequest) String 

func (x *GetStatusRequest) String() string

type Manifest 

type Manifest struct {

	// The list of pages in the manifest
	Pages []*Page `protobuf:"bytes,1,rep,name=pages,proto3" json:"pages,omitempty"`
	// The last page in the manifest
	LastPage *Page `protobuf:"bytes,2,opt,name=last_page,json=lastPage,proto3" json:"last_page,omitempty"`
	// contains filtered or unexported fields
}

Manifest for managing multiple pages

func (*Manifest) Descriptor deprecated 

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

Deprecated: Use Manifest.ProtoReflect.Descriptor instead.

func (*Manifest) GetLastPage 

func (x *Manifest) GetLastPage() *Page

func (*Manifest) GetPages 

func (x *Manifest) GetPages() []*Page

func (*Manifest) ProtoMessage 

func (*Manifest) ProtoMessage()

func (*Manifest) ProtoReflect 

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

func (*Manifest) Reset 

func (x *Manifest) Reset()

func (*Manifest) String 

func (x *Manifest) String() string

type ManifestWrapper 

type ManifestWrapper struct {
	Manifest *Manifest
	Tag      ConcurrencyTag
}

ManifestWrapper is a struct that wraps a stream and an optional concurrency tag.

type MergeArgs 

type MergeArgs struct {

	// The unique identifier of the space containing the partition
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition to merge
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// The numerical level of the tier to merge
	Tier int32 `protobuf:"varint,3,opt,name=tier,proto3" json:"tier,omitempty"`
	// contains filtered or unexported fields
}

Arguments for maintenance operations

func (*MergeArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use MergeArgs.ProtoReflect.Descriptor instead.

func (*MergeArgs) GetPartition added in v0.0.6 

func (x *MergeArgs) GetPartition() string

func (*MergeArgs) GetSpace added in v0.0.6 

func (x *MergeArgs) GetSpace() string

func (*MergeArgs) GetTier added in v0.0.6 

func (x *MergeArgs) GetTier() int32

func (*MergeArgs) ProtoMessage added in v0.0.6 

func (*MergeArgs) ProtoMessage()

func (*MergeArgs) ProtoReflect added in v0.0.6 

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

func (*MergeArgs) Reset added in v0.0.6 

func (x *MergeArgs) Reset()

func (*MergeArgs) String added in v0.0.6 

func (x *MergeArgs) String() string

type MergeRequest 

type MergeRequest struct {

	// The tier to merge
	Tier int32 `protobuf:"varint,1,opt,name=tier,proto3" json:"tier,omitempty"`
	// contains filtered or unexported fields
}

Request to merge a partition at a specific tier

func (*MergeRequest) Descriptor deprecated 

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

Deprecated: Use MergeRequest.ProtoReflect.Descriptor instead.

func (*MergeRequest) GetTier 

func (x *MergeRequest) GetTier() int32

func (*MergeRequest) ProtoMessage 

func (*MergeRequest) ProtoMessage()

func (*MergeRequest) ProtoReflect 

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

func (*MergeRequest) Reset 

func (x *MergeRequest) Reset()

func (*MergeRequest) String 

func (x *MergeRequest) String() string

type Offset 

type Offset struct {

	// The sequence number for the offset
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// The timestamp for the offset
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

Offset structure used for tracking position in a stream

func (*Offset) Descriptor deprecated 

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

Deprecated: Use Offset.ProtoReflect.Descriptor instead.

func (*Offset) GetSequence 

func (x *Offset) GetSequence() uint64

func (*Offset) GetTimestamp 

func (x *Offset) GetTimestamp() int64

func (*Offset) ProtoMessage 

func (*Offset) ProtoMessage()

func (*Offset) ProtoReflect 

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

func (*Offset) Reset 

func (x *Offset) Reset()

func (*Offset) String 

func (x *Offset) String() string

type Page 

type Page struct {

	// The page number
	Number int32 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// The sequence number of the first entry in the page
	FirstSequence uint64 `protobuf:"varint,2,opt,name=first_sequence,json=firstSequence,proto3" json:"first_sequence,omitempty"`
	// The timestamp of the first entry in the page
	FirstTimestamp int64 `protobuf:"varint,3,opt,name=first_timestamp,json=firstTimestamp,proto3" json:"first_timestamp,omitempty"`
	// The sequence number of the last entry in the page
	LastSequence uint64 `protobuf:"varint,4,opt,name=last_sequence,json=lastSequence,proto3" json:"last_sequence,omitempty"`
	// The timestamp of the last entry in the page
	LastTimestamp int64 `protobuf:"varint,5,opt,name=last_timestamp,json=lastTimestamp,proto3" json:"last_timestamp,omitempty"`
	// The number of entries in the page
	Count int32 `protobuf:"varint,6,opt,name=count,proto3" json:"count,omitempty"`
	// The size of the page
	Size int64 `protobuf:"varint,7,opt,name=size,proto3" json:"size,omitempty"`
	// A sparse index of sequences to positions in the IO stream
	Index []*PageIndexEntry `protobuf:"bytes,8,rep,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

A page containing multiple entries and an index for efficient access

func (*Page) Descriptor deprecated 

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

Deprecated: Use Page.ProtoReflect.Descriptor instead.

func (*Page) FindNearestKey 

func (page *Page) FindNearestKey(sequence uint64) (uint64, int64)

Find the nearest key without exceeding the target

func (*Page) GetCount 

func (x *Page) GetCount() int32

func (*Page) GetFirstSequence 

func (x *Page) GetFirstSequence() uint64

func (*Page) GetFirstTimestamp 

func (x *Page) GetFirstTimestamp() int64

func (*Page) GetIndex 

func (x *Page) GetIndex() []*PageIndexEntry

func (*Page) GetLastSequence 

func (x *Page) GetLastSequence() uint64

func (*Page) GetLastTimestamp 

func (x *Page) GetLastTimestamp() int64

func (*Page) GetNumber 

func (x *Page) GetNumber() int32

func (*Page) GetSize 

func (x *Page) GetSize() int64

func (*Page) ProtoMessage 

func (*Page) ProtoMessage()

func (*Page) ProtoReflect 

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

func (*Page) Reset 

func (x *Page) Reset()

func (*Page) String 

func (x *Page) String() string

type PageDescriptor 

type PageDescriptor struct {

	// The unique identifier of the space this page belongs to
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition this page belongs to
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// The numerical level of the tier containing this page
	Tier int32 `protobuf:"varint,3,opt,name=tier,proto3" json:"tier,omitempty"`
	// The sequential page number within the tier
	Number int32 `protobuf:"varint,4,opt,name=number,proto3" json:"number,omitempty"`
	// The sequence number of the first entry stored in this page
	FirstSequence uint64 `protobuf:"varint,5,opt,name=first_sequence,json=firstSequence,proto3" json:"first_sequence,omitempty"`
	// The timestamp of the first entry stored in this page (in milliseconds since epoch)
	FirstTimestamp int64 `protobuf:"varint,6,opt,name=first_timestamp,json=firstTimestamp,proto3" json:"first_timestamp,omitempty"`
	// The sequence number of the last entry stored in this page
	LastSequence uint64 `protobuf:"varint,7,opt,name=last_sequence,json=lastSequence,proto3" json:"last_sequence,omitempty"`
	// The timestamp of the last entry stored in this page (in milliseconds since epoch)
	LastTimestamp int64 `protobuf:"varint,8,opt,name=last_timestamp,json=lastTimestamp,proto3" json:"last_timestamp,omitempty"`
	// The total number of entries stored in this page
	Count int32 `protobuf:"varint,9,opt,name=count,proto3" json:"count,omitempty"`
	// The total size of the page in bytes
	Size int64 `protobuf:"varint,10,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

Descriptor for a page within a partition/tier

func (*PageDescriptor) Descriptor deprecated 

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

Deprecated: Use PageDescriptor.ProtoReflect.Descriptor instead.

func (*PageDescriptor) GetCount 

func (x *PageDescriptor) GetCount() int32

func (*PageDescriptor) GetFirstSequence 

func (x *PageDescriptor) GetFirstSequence() uint64

func (*PageDescriptor) GetFirstTimestamp 

func (x *PageDescriptor) GetFirstTimestamp() int64

func (*PageDescriptor) GetLastSequence 

func (x *PageDescriptor) GetLastSequence() uint64

func (*PageDescriptor) GetLastTimestamp 

func (x *PageDescriptor) GetLastTimestamp() int64

func (*PageDescriptor) GetNumber 

func (x *PageDescriptor) GetNumber() int32

func (*PageDescriptor) GetPartition 

func (x *PageDescriptor) GetPartition() string

func (*PageDescriptor) GetSize 

func (x *PageDescriptor) GetSize() int64

func (*PageDescriptor) GetSpace 

func (x *PageDescriptor) GetSpace() string

func (*PageDescriptor) GetTier 

func (x *PageDescriptor) GetTier() int32

func (*PageDescriptor) ProtoMessage 

func (*PageDescriptor) ProtoMessage()

func (*PageDescriptor) ProtoReflect 

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

func (*PageDescriptor) Reset 

func (x *PageDescriptor) Reset()

func (*PageDescriptor) String 

func (x *PageDescriptor) String() string

type PageIndexEntry 

type PageIndexEntry struct {

	// The sequence number for this index entry
	Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"`
	// The position of the sequence in the stream
	Position int64 `protobuf:"varint,2,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

Index entry for efficient sequence lookup in a page

func (*PageIndexEntry) Descriptor deprecated 

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

Deprecated: Use PageIndexEntry.ProtoReflect.Descriptor instead.

func (*PageIndexEntry) GetPosition 

func (x *PageIndexEntry) GetPosition() int64

func (*PageIndexEntry) GetSequence 

func (x *PageIndexEntry) GetSequence() uint64

func (*PageIndexEntry) ProtoMessage 

func (*PageIndexEntry) ProtoMessage()

func (*PageIndexEntry) ProtoReflect 

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

func (*PageIndexEntry) Reset 

func (x *PageIndexEntry) Reset()

func (*PageIndexEntry) String 

func (x *PageIndexEntry) String() string

type PartitionDescriptor 

type PartitionDescriptor struct {

	// The unique identifier of the space this partition belongs to
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition within the space
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

Descriptor for a partition

func (*PartitionDescriptor) Descriptor deprecated 

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

Deprecated: Use PartitionDescriptor.ProtoReflect.Descriptor instead.

func (*PartitionDescriptor) GetPartition 

func (x *PartitionDescriptor) GetPartition() string

func (*PartitionDescriptor) GetSpace 

func (x *PartitionDescriptor) GetSpace() string

func (*PartitionDescriptor) ProtoMessage 

func (*PartitionDescriptor) ProtoMessage()

func (*PartitionDescriptor) ProtoReflect 

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

func (*PartitionDescriptor) Reset 

func (x *PartitionDescriptor) Reset()

func (*PartitionDescriptor) String 

func (x *PartitionDescriptor) String() string

type PartitionOffsets added in v0.0.8 

type PartitionOffsets struct {

	// Map of offsets by partition
	Offsets map[string]*Offset `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

A structure used for tracking all of the partition offsets in a space

func NewPartitionOffsets added in v0.0.8 

func NewPartitionOffsets(data []byte) *PartitionOffsets

func (*PartitionOffsets) Descriptor deprecated added in v0.0.8 

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

Deprecated: Use PartitionOffsets.ProtoReflect.Descriptor instead.

func (*PartitionOffsets) Get added in v0.0.8 

func (o *PartitionOffsets) Get(partition string) *Offset

func (*PartitionOffsets) GetOffsetMap added in v0.0.8 

func (o *PartitionOffsets) GetOffsetMap() map[string]*Offset

func (*PartitionOffsets) GetOffsets added in v0.0.8 

func (x *PartitionOffsets) GetOffsets() map[string]*Offset

func (*PartitionOffsets) Marshal added in v0.0.8 

func (o *PartitionOffsets) Marshal() []byte

func (*PartitionOffsets) ProtoMessage added in v0.0.8 

func (*PartitionOffsets) ProtoMessage()

func (*PartitionOffsets) ProtoReflect added in v0.0.8 

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

func (*PartitionOffsets) Reset added in v0.0.8 

func (x *PartitionOffsets) Reset()

func (*PartitionOffsets) Set added in v0.0.8 

func (o *PartitionOffsets) Set(partition string, offset *Offset)

func (*PartitionOffsets) String added in v0.0.8 

func (x *PartitionOffsets) String() string

func (*PartitionOffsets) Unmarshal added in v0.0.8 

func (o *PartitionOffsets) Unmarshal(data []byte) *PartitionOffsets

type PeekArgs 

type PeekArgs struct {

	// The unique identifier of the space containing the partition
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition to peek at
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

func (*PeekArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use PeekArgs.ProtoReflect.Descriptor instead.

func (*PeekArgs) GetPartition added in v0.0.6 

func (x *PeekArgs) GetPartition() string

func (*PeekArgs) GetSpace added in v0.0.6 

func (x *PeekArgs) GetSpace() string

func (*PeekArgs) ProtoMessage added in v0.0.6 

func (*PeekArgs) ProtoMessage()

func (*PeekArgs) ProtoReflect added in v0.0.6 

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

func (*PeekArgs) Reset added in v0.0.6 

func (x *PeekArgs) Reset()

func (*PeekArgs) String added in v0.0.6 

func (x *PeekArgs) String() string

type PeekRequest 

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

Request to peek at entries in a space

func (*PeekRequest) Descriptor deprecated 

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

Deprecated: Use PeekRequest.ProtoReflect.Descriptor instead.

func (*PeekRequest) ProtoMessage 

func (*PeekRequest) ProtoMessage()

func (*PeekRequest) ProtoReflect 

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

func (*PeekRequest) Reset 

func (x *PeekRequest) Reset()

func (*PeekRequest) String 

func (x *PeekRequest) String() string

type ProduceArgs 

type ProduceArgs struct {

	// The unique identifier of the space containing the partition
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition to produce entries to
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// The strategy to use for producing entries (e.g., "append", "upsert")
	Strategy string `protobuf:"bytes,3,opt,name=strategy,proto3" json:"strategy,omitempty"`
	// contains filtered or unexported fields
}

Arguments for data operations

func (*ProduceArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use ProduceArgs.ProtoReflect.Descriptor instead.

func (*ProduceArgs) GetPartition added in v0.0.6 

func (x *ProduceArgs) GetPartition() string

func (*ProduceArgs) GetSpace added in v0.0.6 

func (x *ProduceArgs) GetSpace() string

func (*ProduceArgs) GetStrategy added in v0.0.6 

func (x *ProduceArgs) GetStrategy() string

func (*ProduceArgs) ProtoMessage added in v0.0.6 

func (*ProduceArgs) ProtoMessage()

func (*ProduceArgs) ProtoReflect added in v0.0.6 

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

func (*ProduceArgs) Reset added in v0.0.6 

func (x *ProduceArgs) Reset()

func (*ProduceArgs) String added in v0.0.6 

func (x *ProduceArgs) String() string

type PruneArgs 

type PruneArgs struct {

	// The unique identifier of the space containing the partition
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition to prune
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// The numerical level of the tier to prune
	Tier int32 `protobuf:"varint,3,opt,name=tier,proto3" json:"tier,omitempty"`
	// contains filtered or unexported fields
}

func (*PruneArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use PruneArgs.ProtoReflect.Descriptor instead.

func (*PruneArgs) GetPartition added in v0.0.6 

func (x *PruneArgs) GetPartition() string

func (*PruneArgs) GetSpace added in v0.0.6 

func (x *PruneArgs) GetSpace() string

func (*PruneArgs) GetTier added in v0.0.6 

func (x *PruneArgs) GetTier() int32

func (*PruneArgs) ProtoMessage added in v0.0.6 

func (*PruneArgs) ProtoMessage()

func (*PruneArgs) ProtoReflect added in v0.0.6 

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

func (*PruneArgs) Reset added in v0.0.6 

func (x *PruneArgs) Reset()

func (*PruneArgs) String added in v0.0.6 

func (x *PruneArgs) String() string

type PruneRequest 

type PruneRequest struct {

	// The tier to prune
	Tier int32 `protobuf:"varint,1,opt,name=tier,proto3" json:"tier,omitempty"`
	// contains filtered or unexported fields
}

Request to prune a partition at a specific tier

func (*PruneRequest) Descriptor deprecated 

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

Deprecated: Use PruneRequest.ProtoReflect.Descriptor instead.

func (*PruneRequest) GetTier 

func (x *PruneRequest) GetTier() int32

func (*PruneRequest) ProtoMessage 

func (*PruneRequest) ProtoMessage()

func (*PruneRequest) ProtoReflect 

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

func (*PruneRequest) Reset 

func (x *PruneRequest) Reset()

func (*PruneRequest) String 

func (x *PruneRequest) String() string

type ReadManifestArgs 

type ReadManifestArgs struct {
	Tenant    string `json:"tenant"`
	Space     string `json:"space"`
	Partition string `json:"partition"`
	Tier      int32  `json:"tier"`
}

Arguments for ReadManifest operation

type ReadPageArgs 

type ReadPageArgs struct {

	// The unique identifier of the space containing the partition
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition containing the page
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// The numerical level of the tier containing the page
	Tier int32 `protobuf:"varint,3,opt,name=tier,proto3" json:"tier,omitempty"`
	// The sequential page number to read
	Number int32 `protobuf:"varint,4,opt,name=number,proto3" json:"number,omitempty"`
	// The position within the page to start reading from
	Position int64 `protobuf:"varint,5,opt,name=position,proto3" json:"position,omitempty"`
	// contains filtered or unexported fields
}

Arguments for page operations

func (*ReadPageArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use ReadPageArgs.ProtoReflect.Descriptor instead.

func (*ReadPageArgs) GetNumber added in v0.0.6 

func (x *ReadPageArgs) GetNumber() int32

func (*ReadPageArgs) GetPartition added in v0.0.6 

func (x *ReadPageArgs) GetPartition() string

func (*ReadPageArgs) GetPosition added in v0.0.6 

func (x *ReadPageArgs) GetPosition() int64

func (*ReadPageArgs) GetSpace added in v0.0.6 

func (x *ReadPageArgs) GetSpace() string

func (*ReadPageArgs) GetTier added in v0.0.6 

func (x *ReadPageArgs) GetTier() int32

func (*ReadPageArgs) ProtoMessage added in v0.0.6 

func (*ReadPageArgs) ProtoMessage()

func (*ReadPageArgs) ProtoReflect added in v0.0.6 

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

func (*ReadPageArgs) Reset added in v0.0.6 

func (x *ReadPageArgs) Reset()

func (*ReadPageArgs) String added in v0.0.6 

func (x *ReadPageArgs) String() string

type RebuildArgs 

type RebuildArgs struct {

	// The unique identifier of the space containing the partition
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition to rebuild
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// The numerical level of the tier to rebuild
	Tier int32 `protobuf:"varint,3,opt,name=tier,proto3" json:"tier,omitempty"`
	// contains filtered or unexported fields
}

func (*RebuildArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use RebuildArgs.ProtoReflect.Descriptor instead.

func (*RebuildArgs) GetPartition added in v0.0.6 

func (x *RebuildArgs) GetPartition() string

func (*RebuildArgs) GetSpace added in v0.0.6 

func (x *RebuildArgs) GetSpace() string

func (*RebuildArgs) GetTier added in v0.0.6 

func (x *RebuildArgs) GetTier() int32

func (*RebuildArgs) ProtoMessage added in v0.0.6 

func (*RebuildArgs) ProtoMessage()

func (*RebuildArgs) ProtoReflect added in v0.0.6 

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

func (*RebuildArgs) Reset added in v0.0.6 

func (x *RebuildArgs) Reset()

func (*RebuildArgs) String added in v0.0.6 

func (x *RebuildArgs) String() string

type RebuildRequest 

type RebuildRequest struct {

	// The tier to rebuild
	Tier int32 `protobuf:"varint,1,opt,name=tier,proto3" json:"tier,omitempty"`
	// contains filtered or unexported fields
}

Request to rebuild a partition at a specific tier

func (*RebuildRequest) Descriptor deprecated 

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

Deprecated: Use RebuildRequest.ProtoReflect.Descriptor instead.

func (*RebuildRequest) GetTier 

func (x *RebuildRequest) GetTier() int32

func (*RebuildRequest) ProtoMessage 

func (*RebuildRequest) ProtoMessage()

func (*RebuildRequest) ProtoReflect 

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

func (*RebuildRequest) Reset 

func (x *RebuildRequest) Reset()

func (*RebuildRequest) String 

func (x *RebuildRequest) String() string

type RebuildResponse 

type RebuildResponse struct {

	// The partition being rebuilt
	Partition string `protobuf:"bytes,1,opt,name=partition,proto3" json:"partition,omitempty"`
	// The tier being rebuilt
	Tier int32 `protobuf:"varint,2,opt,name=tier,proto3" json:"tier,omitempty"`
	// The number of pages rebuilt
	PageCount int32 `protobuf:"varint,3,opt,name=page_count,json=pageCount,proto3" json:"page_count,omitempty"`
	// contains filtered or unexported fields
}

Response for a rebuild operation

func (*RebuildResponse) Descriptor deprecated 

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

Deprecated: Use RebuildResponse.ProtoReflect.Descriptor instead.

func (*RebuildResponse) GetPageCount 

func (x *RebuildResponse) GetPageCount() int32

func (*RebuildResponse) GetPartition 

func (x *RebuildResponse) GetPartition() string

func (*RebuildResponse) GetTier 

func (x *RebuildResponse) GetTier() int32

func (*RebuildResponse) ProtoMessage 

func (*RebuildResponse) ProtoMessage()

func (*RebuildResponse) ProtoReflect 

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

func (*RebuildResponse) Reset 

func (x *RebuildResponse) Reset()

func (*RebuildResponse) String 

func (x *RebuildResponse) String() string

type SpaceDescriptor 

type SpaceDescriptor struct {

	// The unique identifier of the space, used to organize related partitions
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// contains filtered or unexported fields
}

Descriptor for a space

func (*SpaceDescriptor) Descriptor deprecated 

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

Deprecated: Use SpaceDescriptor.ProtoReflect.Descriptor instead.

func (*SpaceDescriptor) GetSpace 

func (x *SpaceDescriptor) GetSpace() string

func (*SpaceDescriptor) ProtoMessage 

func (*SpaceDescriptor) ProtoMessage()

func (*SpaceDescriptor) ProtoReflect 

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

func (*SpaceDescriptor) Reset 

func (x *SpaceDescriptor) Reset()

func (*SpaceDescriptor) String 

func (x *SpaceDescriptor) String() string

type SpaceOffsets added in v0.0.8 

type SpaceOffsets struct {
	Offsets map[string]*PartitionOffsets `` /* 141-byte string literal not displayed */
	// contains filtered or unexported fields
}

A structure used for tracking all of the partition offsets in a map of spaces

func NewSpaceOffsets added in v0.0.8 

func NewSpaceOffsets(data []byte) *SpaceOffsets

func (*SpaceOffsets) Descriptor deprecated added in v0.0.8 

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

Deprecated: Use SpaceOffsets.ProtoReflect.Descriptor instead.

func (*SpaceOffsets) GetOffset added in v0.0.8 

func (o *SpaceOffsets) GetOffset(space, partition string) *Offset

func (*SpaceOffsets) GetOffsetMap added in v0.0.8 

func (o *SpaceOffsets) GetOffsetMap(space string) map[string]*Offset

func (*SpaceOffsets) GetOffsets added in v0.0.8 

func (x *SpaceOffsets) GetOffsets() map[string]*PartitionOffsets

func (*SpaceOffsets) Marshal added in v0.0.8 

func (o *SpaceOffsets) Marshal() []byte

func (*SpaceOffsets) ProtoMessage added in v0.0.8 

func (*SpaceOffsets) ProtoMessage()

func (*SpaceOffsets) ProtoReflect added in v0.0.8 

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

func (*SpaceOffsets) Reset added in v0.0.8 

func (x *SpaceOffsets) Reset()

func (*SpaceOffsets) Set added in v0.0.8 

func (o *SpaceOffsets) Set(space, partition string, offset *Offset)

func (*SpaceOffsets) SetOffsetFromEnvelope added in v0.0.8 

func (o *SpaceOffsets) SetOffsetFromEnvelope(envelope *EntryEnvelope)

func (*SpaceOffsets) String added in v0.0.8 

func (x *SpaceOffsets) String() string

func (*SpaceOffsets) Unmarshal added in v0.0.8 

func (o *SpaceOffsets) Unmarshal(data []byte) *SpaceOffsets

type StatusResponse 

type StatusResponse struct {

	// The status message
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

Response with status message

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetMessage 

func (x *StatusResponse) GetMessage() string

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type TierDescriptor 

type TierDescriptor struct {

	// The unique identifier of the space this tier belongs to
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition this tier belongs to
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// The numerical level of the tier, where lower numbers indicate more recent data
	Tier int32 `protobuf:"varint,3,opt,name=tier,proto3" json:"tier,omitempty"`
	// contains filtered or unexported fields
}

Descriptor for a tier within a partition

func (*TierDescriptor) Descriptor deprecated 

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

Deprecated: Use TierDescriptor.ProtoReflect.Descriptor instead.

func (*TierDescriptor) GetPartition 

func (x *TierDescriptor) GetPartition() string

func (*TierDescriptor) GetSpace 

func (x *TierDescriptor) GetSpace() string

func (*TierDescriptor) GetTier 

func (x *TierDescriptor) GetTier() int32

func (*TierDescriptor) ProtoMessage 

func (*TierDescriptor) ProtoMessage()

func (*TierDescriptor) ProtoReflect 

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

func (*TierDescriptor) Reset 

func (x *TierDescriptor) Reset()

func (*TierDescriptor) String 

func (x *TierDescriptor) String() string

type TieredPage 

type TieredPage struct {
	Tier int32
	Page *Page
}

TieredPage represents a page with tiering information.

type WriteManifestArgs 

type WriteManifestArgs struct {
	Tenant    string         `json:"tenant"`
	Space     string         `json:"space"`
	Partition string         `json:"partition"`
	Tier      int32          `json:"tier"`
	Tag       ConcurrencyTag `json:"tag"`
	Manifest  *Manifest      `json:"manifest"`
}

Arguments for WriteManifest operation

type WritePageArgs 

type WritePageArgs struct {

	// The unique identifier of the space containing the partition
	Space string `protobuf:"bytes,1,opt,name=space,proto3" json:"space,omitempty"`
	// The unique identifier of the partition to write to
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// The numerical level of the tier to write to
	Tier int32 `protobuf:"varint,3,opt,name=tier,proto3" json:"tier,omitempty"`
	// The sequential page number to write
	Number int32 `protobuf:"varint,4,opt,name=number,proto3" json:"number,omitempty"`
	// The minimum size a page should be in bytes
	MinPageSize int64 `protobuf:"varint,5,opt,name=min_page_size,json=minPageSize,proto3" json:"min_page_size,omitempty"`
	// The maximum size a page can be in bytes
	MaxPageSize int64 `protobuf:"varint,6,opt,name=max_page_size,json=maxPageSize,proto3" json:"max_page_size,omitempty"`
	// The entries to write to the page
	Entries []*Entry `protobuf:"bytes,7,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*WritePageArgs) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use WritePageArgs.ProtoReflect.Descriptor instead.

func (*WritePageArgs) GetEntries added in v0.0.6 

func (x *WritePageArgs) GetEntries() []*Entry

func (*WritePageArgs) GetMaxPageSize added in v0.0.6 

func (x *WritePageArgs) GetMaxPageSize() int64

func (*WritePageArgs) GetMinPageSize added in v0.0.6 

func (x *WritePageArgs) GetMinPageSize() int64

func (*WritePageArgs) GetNumber added in v0.0.6 

func (x *WritePageArgs) GetNumber() int32

func (*WritePageArgs) GetPartition added in v0.0.6 

func (x *WritePageArgs) GetPartition() string

func (*WritePageArgs) GetSpace added in v0.0.6 

func (x *WritePageArgs) GetSpace() string

func (*WritePageArgs) GetTier added in v0.0.6 

func (x *WritePageArgs) GetTier() int32

func (*WritePageArgs) ProtoMessage added in v0.0.6 

func (*WritePageArgs) ProtoMessage()

func (*WritePageArgs) ProtoReflect added in v0.0.6 

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

func (*WritePageArgs) Reset added in v0.0.6 

func (x *WritePageArgs) Reset()

func (*WritePageArgs) String added in v0.0.6 

func (x *WritePageArgs) String() string

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.