internalpb

package
v1.118.7 Latest Latest
Warning

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

 Go to latest Published: Nov 26, 2024 License: AGPL-3.0 Imports: 12 Imported by: 3

Documentation

Overview

Package internalpb contains proto definitions for satellite internal tools.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DRPCRegisterRepairCoordinator 

func DRPCRegisterRepairCoordinator(mux drpc.Mux, impl DRPCRepairCoordinatorServer) error

Types

type DRPCRepairCoordinatorClient 

type DRPCRepairCoordinatorClient interface {
	DRPCConn() drpc.Conn

	RepairJob(ctx context.Context, in *RepairJobRequest) (*RepairJobResponse, error)
}

func NewDRPCRepairCoordinatorClient 

func NewDRPCRepairCoordinatorClient(cc drpc.Conn) DRPCRepairCoordinatorClient

type DRPCRepairCoordinatorDescription 

type DRPCRepairCoordinatorDescription struct{}

func (DRPCRepairCoordinatorDescription) Method 

func (DRPCRepairCoordinatorDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCRepairCoordinatorDescription) NumMethods 

func (DRPCRepairCoordinatorDescription) NumMethods() int

type DRPCRepairCoordinatorServer 

type DRPCRepairCoordinatorServer interface {
	RepairJob(context.Context, *RepairJobRequest) (*RepairJobResponse, error)
}

type DRPCRepairCoordinatorUnimplementedServer added in v1.26.2 

type DRPCRepairCoordinatorUnimplementedServer struct{}

func (*DRPCRepairCoordinatorUnimplementedServer) RepairJob added in v1.26.2 

func (s *DRPCRepairCoordinatorUnimplementedServer) RepairJob(context.Context, *RepairJobRequest) (*RepairJobResponse, error)

type DRPCRepairCoordinator_RepairJobStream 

type DRPCRepairCoordinator_RepairJobStream interface {
	drpc.Stream
	SendAndClose(*RepairJobResponse) error
}

type NodeID 

type NodeID = storj.NodeID

NodeID is an alias to storj.NodeID for use in generated protobuf code.

type OrderLimitMetadata added in v1.19.9 

type OrderLimitMetadata struct {
	BucketId                   []byte   `protobuf:"bytes,1,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	ProjectBucketPrefix        []byte   `protobuf:"bytes,2,opt,name=project_bucket_prefix,json=projectBucketPrefix,proto3" json:"project_bucket_prefix,omitempty"`
	CompactProjectBucketPrefix []byte   `` /* 143-byte string literal not displayed */
	XXX_NoUnkeyedLiteral       struct{} `json:"-"`
	XXX_unrecognized           []byte   `json:"-"`
	XXX_sizecache              int32    `json:"-"`
}

OrderLimitMetadata is used to transmit meta information about an order limit. This data will be encrypted.

func (*OrderLimitMetadata) Descriptor added in v1.19.9 

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

func (*OrderLimitMetadata) GetBucketId added in v1.19.9 

func (m *OrderLimitMetadata) GetBucketId() []byte

func (*OrderLimitMetadata) GetCompactProjectBucketPrefix added in v1.19.9 

func (m *OrderLimitMetadata) GetCompactProjectBucketPrefix() []byte

func (*OrderLimitMetadata) GetProjectBucketPrefix added in v1.19.9 

func (m *OrderLimitMetadata) GetProjectBucketPrefix() []byte

func (*OrderLimitMetadata) ProtoMessage added in v1.19.9 

func (*OrderLimitMetadata) ProtoMessage()

func (*OrderLimitMetadata) Reset added in v1.19.9 

func (m *OrderLimitMetadata) Reset()

func (*OrderLimitMetadata) String added in v1.19.9 

func (m *OrderLimitMetadata) String() string

func (*OrderLimitMetadata) XXX_DiscardUnknown added in v1.19.9 

func (m *OrderLimitMetadata) XXX_DiscardUnknown()

func (*OrderLimitMetadata) XXX_Marshal added in v1.19.9 

func (m *OrderLimitMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OrderLimitMetadata) XXX_Merge added in v1.19.9 

func (m *OrderLimitMetadata) XXX_Merge(src proto.Message)

func (*OrderLimitMetadata) XXX_Size added in v1.19.9 

func (m *OrderLimitMetadata) XXX_Size() int

func (*OrderLimitMetadata) XXX_Unmarshal added in v1.19.9 

func (m *OrderLimitMetadata) XXX_Unmarshal(b []byte) error

type PieceID 

type PieceID = storj.PieceID

PieceID is an alias to storj.PieceID for use in generated protobuf code.

type RepairJobDefinition 

type RepairJobDefinition struct {
	// Identifier for this job
	JobId []byte `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Signed GET orders for all believed-healthy pieces to be downloaded
	GetOrders []*pb.AddressedOrderLimit `protobuf:"bytes,2,rep,name=get_orders,json=getOrders,proto3" json:"get_orders,omitempty"`
	// Private piece key to use for fetching
	PrivateKeyForGet []byte `protobuf:"bytes,3,opt,name=private_key_for_get,json=privateKeyForGet,proto3" json:"private_key_for_get,omitempty"`
	// Signed PUT orders for all possible pieces to be uploaded (not including
	// piece numbers in get_orders)
	PutOrders []*pb.AddressedOrderLimit `protobuf:"bytes,4,rep,name=put_orders,json=putOrders,proto3" json:"put_orders,omitempty"`
	// Private piece key to use for storing
	PrivateKeyForPut []byte `protobuf:"bytes,5,opt,name=private_key_for_put,json=privateKeyForPut,proto3" json:"private_key_for_put,omitempty"`
	// Redundancy scheme used by the segment to be repaired
	Redundancy *pb.RedundancyScheme `protobuf:"bytes,6,opt,name=redundancy,proto3" json:"redundancy,omitempty"`
	// Size of the segment to be repaired
	SegmentSize int64 `protobuf:"varint,7,opt,name=segment_size,json=segmentSize,proto3" json:"segment_size,omitempty"`
	// Target piece count (worker should try to upload enough pieces so that
	// this count is achieved)
	DesiredPieceCount int32 `protobuf:"varint,8,opt,name=desired_piece_count,json=desiredPieceCount,proto3" json:"desired_piece_count,omitempty"`
	// Job expiration time
	ExpirationTime       time.Time `protobuf:"bytes,9,opt,name=expiration_time,json=expirationTime,proto3,stdtime" json:"expiration_time"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*RepairJobDefinition) Descriptor 

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

func (*RepairJobDefinition) GetDesiredPieceCount 

func (m *RepairJobDefinition) GetDesiredPieceCount() int32

func (*RepairJobDefinition) GetExpirationTime 

func (m *RepairJobDefinition) GetExpirationTime() time.Time

func (*RepairJobDefinition) GetGetOrders 

func (m *RepairJobDefinition) GetGetOrders() []*pb.AddressedOrderLimit

func (*RepairJobDefinition) GetJobId 

func (m *RepairJobDefinition) GetJobId() []byte

func (*RepairJobDefinition) GetPrivateKeyForGet 

func (m *RepairJobDefinition) GetPrivateKeyForGet() []byte

func (*RepairJobDefinition) GetPrivateKeyForPut 

func (m *RepairJobDefinition) GetPrivateKeyForPut() []byte

func (*RepairJobDefinition) GetPutOrders 

func (m *RepairJobDefinition) GetPutOrders() []*pb.AddressedOrderLimit

func (*RepairJobDefinition) GetRedundancy 

func (m *RepairJobDefinition) GetRedundancy() *pb.RedundancyScheme

func (*RepairJobDefinition) GetSegmentSize 

func (m *RepairJobDefinition) GetSegmentSize() int64

func (*RepairJobDefinition) ProtoMessage 

func (*RepairJobDefinition) ProtoMessage()

func (*RepairJobDefinition) Reset 

func (m *RepairJobDefinition) Reset()

func (*RepairJobDefinition) String 

func (m *RepairJobDefinition) String() string

func (*RepairJobDefinition) XXX_DiscardUnknown 

func (m *RepairJobDefinition) XXX_DiscardUnknown()

func (*RepairJobDefinition) XXX_Marshal 

func (m *RepairJobDefinition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RepairJobDefinition) XXX_Merge 

func (m *RepairJobDefinition) XXX_Merge(src proto.Message)

func (*RepairJobDefinition) XXX_Size 

func (m *RepairJobDefinition) XXX_Size() int

func (*RepairJobDefinition) XXX_Unmarshal 

func (m *RepairJobDefinition) XXX_Unmarshal(b []byte) error

type RepairJobRequest 

type RepairJobRequest struct {
	// When not the first request, this will include the result of the last job
	LastJobResult        *RepairJobResult `protobuf:"bytes,1,opt,name=last_job_result,json=lastJobResult,proto3" json:"last_job_result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*RepairJobRequest) Descriptor 

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

func (*RepairJobRequest) GetLastJobResult 

func (m *RepairJobRequest) GetLastJobResult() *RepairJobResult

func (*RepairJobRequest) ProtoMessage 

func (*RepairJobRequest) ProtoMessage()

func (*RepairJobRequest) Reset 

func (m *RepairJobRequest) Reset()

func (*RepairJobRequest) String 

func (m *RepairJobRequest) String() string

func (*RepairJobRequest) XXX_DiscardUnknown 

func (m *RepairJobRequest) XXX_DiscardUnknown()

func (*RepairJobRequest) XXX_Marshal 

func (m *RepairJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RepairJobRequest) XXX_Merge 

func (m *RepairJobRequest) XXX_Merge(src proto.Message)

func (*RepairJobRequest) XXX_Size 

func (m *RepairJobRequest) XXX_Size() int

func (*RepairJobRequest) XXX_Unmarshal 

func (m *RepairJobRequest) XXX_Unmarshal(b []byte) error

type RepairJobResponse 

type RepairJobResponse struct {
	// When a job is available, this will be filled in
	NewJob *RepairJobDefinition `protobuf:"bytes,1,opt,name=new_job,json=newJob,proto3" json:"new_job,omitempty"`
	// Otherwise, client should wait this many milliseconds and then try again
	ComeBackInMillis     int32    `protobuf:"varint,2,opt,name=come_back_in_millis,json=comeBackInMillis,proto3" json:"come_back_in_millis,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RepairJobResponse) Descriptor 

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

func (*RepairJobResponse) GetComeBackInMillis 

func (m *RepairJobResponse) GetComeBackInMillis() int32

func (*RepairJobResponse) GetNewJob 

func (m *RepairJobResponse) GetNewJob() *RepairJobDefinition

func (*RepairJobResponse) ProtoMessage 

func (*RepairJobResponse) ProtoMessage()

func (*RepairJobResponse) Reset 

func (m *RepairJobResponse) Reset()

func (*RepairJobResponse) String 

func (m *RepairJobResponse) String() string

func (*RepairJobResponse) XXX_DiscardUnknown 

func (m *RepairJobResponse) XXX_DiscardUnknown()

func (*RepairJobResponse) XXX_Marshal 

func (m *RepairJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RepairJobResponse) XXX_Merge 

func (m *RepairJobResponse) XXX_Merge(src proto.Message)

func (*RepairJobResponse) XXX_Size 

func (m *RepairJobResponse) XXX_Size() int

func (*RepairJobResponse) XXX_Unmarshal 

func (m *RepairJobResponse) XXX_Unmarshal(b []byte) error

type RepairJobResult 

type RepairJobResult struct {
	// Identifier for this job, as given in RepairJobResponse
	JobId []byte `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Set nonzero only if the segment could not be reconstructed because of
	// too few pieces available.
	IrreparablePiecesRetrieved int32 `` /* 142-byte string literal not displayed */
	// Set only if the segment could not be reconstructed.
	ReconstructError string `protobuf:"bytes,3,opt,name=reconstruct_error,json=reconstructError,proto3" json:"reconstruct_error,omitempty"`
	// Set only if new pieces could not be stored to any new nodes.
	StoreError string `protobuf:"bytes,4,opt,name=store_error,json=storeError,proto3" json:"store_error,omitempty"`
	// PieceHashes signed by storage nodes which were used to accomplish repair
	NewPiecesStored []*pb.PieceHash `protobuf:"bytes,5,rep,name=new_pieces_stored,json=newPiecesStored,proto3" json:"new_pieces_stored,omitempty"`
	// A copy of the put_orders list as provided in the corresponding
	// RepairJobDefinition
	PutOrders []*pb.AddressedOrderLimit `protobuf:"bytes,6,rep,name=put_orders,json=putOrders,proto3" json:"put_orders,omitempty"`
	// Pieces which should be _removed_ from the pointer. This will include
	// pieces for which the expected owning storage node returned a "not found"
	// error, as well as pieces which were downloaded but failed their
	// validation check.
	DeletePieceNums      []int32  `protobuf:"varint,7,rep,packed,name=delete_piece_nums,json=deletePieceNums,proto3" json:"delete_piece_nums,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RepairJobResult) Descriptor 

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

func (*RepairJobResult) GetDeletePieceNums 

func (m *RepairJobResult) GetDeletePieceNums() []int32

func (*RepairJobResult) GetIrreparablePiecesRetrieved 

func (m *RepairJobResult) GetIrreparablePiecesRetrieved() int32

func (*RepairJobResult) GetJobId 

func (m *RepairJobResult) GetJobId() []byte

func (*RepairJobResult) GetNewPiecesStored 

func (m *RepairJobResult) GetNewPiecesStored() []*pb.PieceHash

func (*RepairJobResult) GetPutOrders 

func (m *RepairJobResult) GetPutOrders() []*pb.AddressedOrderLimit

func (*RepairJobResult) GetReconstructError 

func (m *RepairJobResult) GetReconstructError() string

func (*RepairJobResult) GetStoreError 

func (m *RepairJobResult) GetStoreError() string

func (*RepairJobResult) ProtoMessage 

func (*RepairJobResult) ProtoMessage()

func (*RepairJobResult) Reset 

func (m *RepairJobResult) Reset()

func (*RepairJobResult) String 

func (m *RepairJobResult) String() string

func (*RepairJobResult) XXX_DiscardUnknown 

func (m *RepairJobResult) XXX_DiscardUnknown()

func (*RepairJobResult) XXX_Marshal 

func (m *RepairJobResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RepairJobResult) XXX_Merge 

func (m *RepairJobResult) XXX_Merge(src proto.Message)

func (*RepairJobResult) XXX_Size 

func (m *RepairJobResult) XXX_Size() int

func (*RepairJobResult) XXX_Unmarshal 

func (m *RepairJobResult) XXX_Unmarshal(b []byte) error

type RetainInfo added in v1.63.1 

type RetainInfo struct {
	CreationDate time.Time `protobuf:"bytes,1,opt,name=creation_date,json=creationDate,proto3,stdtime" json:"creation_date"`
	Filter       []byte    `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	// number of pieces to retain on the node through the above bloom filter.
	PieceCount           int64    `protobuf:"varint,3,opt,name=piece_count,json=pieceCount,proto3" json:"piece_count,omitempty"`
	StorageNodeId        NodeID   `protobuf:"bytes,4,opt,name=storage_node_id,json=storageNodeId,proto3,customtype=NodeID" json:"storage_node_id"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RetainInfo is used to pass info generated from a database backup to the live garbage collection (gc) process. The live process will send it out to the storage nodes.

func (*RetainInfo) Descriptor added in v1.63.1 

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

func (*RetainInfo) GetCreationDate added in v1.63.1 

func (m *RetainInfo) GetCreationDate() time.Time

func (*RetainInfo) GetFilter added in v1.63.1 

func (m *RetainInfo) GetFilter() []byte

func (*RetainInfo) GetPieceCount added in v1.63.1 

func (m *RetainInfo) GetPieceCount() int64

func (*RetainInfo) ProtoMessage added in v1.63.1 

func (*RetainInfo) ProtoMessage()

func (*RetainInfo) Reset added in v1.63.1 

func (m *RetainInfo) Reset()

func (*RetainInfo) String added in v1.63.1 

func (m *RetainInfo) String() string

func (*RetainInfo) XXX_DiscardUnknown added in v1.63.1 

func (m *RetainInfo) XXX_DiscardUnknown()

func (*RetainInfo) XXX_Marshal added in v1.63.1 

func (m *RetainInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RetainInfo) XXX_Merge added in v1.63.1 

func (m *RetainInfo) XXX_Merge(src proto.Message)

func (*RetainInfo) XXX_Size added in v1.63.1 

func (m *RetainInfo) XXX_Size() int

func (*RetainInfo) XXX_Unmarshal added in v1.63.1 

func (m *RetainInfo) XXX_Unmarshal(b []byte) error

type SegmentID 

type SegmentID struct {
	StreamId             *StreamID                 `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	PartNumber           int32                     `protobuf:"varint,2,opt,name=part_number,json=partNumber,proto3" json:"part_number,omitempty"`
	Index                int32                     `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	RootPieceId          PieceID                   `protobuf:"bytes,5,opt,name=root_piece_id,json=rootPieceId,proto3,customtype=PieceID" json:"root_piece_id"`
	OriginalOrderLimits  []*pb.AddressedOrderLimit `protobuf:"bytes,6,rep,name=original_order_limits,json=originalOrderLimits,proto3" json:"original_order_limits,omitempty"`
	CreationDate         time.Time                 `protobuf:"bytes,7,opt,name=creation_date,json=creationDate,proto3,stdtime" json:"creation_date"`
	RedundancyScheme     *pb.RedundancyScheme      `protobuf:"bytes,9,opt,name=redundancy_scheme,json=redundancyScheme,proto3" json:"redundancy_scheme,omitempty"`
	SatelliteSignature   []byte                    `protobuf:"bytes,8,opt,name=satellite_signature,json=satelliteSignature,proto3" json:"satellite_signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*SegmentID) Descriptor 

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

func (*SegmentID) GetCreationDate 

func (m *SegmentID) GetCreationDate() time.Time

func (*SegmentID) GetIndex 

func (m *SegmentID) GetIndex() int32

func (*SegmentID) GetOriginalOrderLimits 

func (m *SegmentID) GetOriginalOrderLimits() []*pb.AddressedOrderLimit

func (*SegmentID) GetPartNumber 

func (m *SegmentID) GetPartNumber() int32

func (*SegmentID) GetRedundancyScheme added in v1.114.4 

func (m *SegmentID) GetRedundancyScheme() *pb.RedundancyScheme

func (*SegmentID) GetSatelliteSignature 

func (m *SegmentID) GetSatelliteSignature() []byte

func (*SegmentID) GetStreamId 

func (m *SegmentID) GetStreamId() *StreamID

func (*SegmentID) ProtoMessage 

func (*SegmentID) ProtoMessage()

func (*SegmentID) Reset 

func (m *SegmentID) Reset()

func (*SegmentID) String 

func (m *SegmentID) String() string

func (*SegmentID) XXX_DiscardUnknown 

func (m *SegmentID) XXX_DiscardUnknown()

func (*SegmentID) XXX_Marshal 

func (m *SegmentID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SegmentID) XXX_Merge 

func (m *SegmentID) XXX_Merge(src proto.Message)

func (*SegmentID) XXX_Size 

func (m *SegmentID) XXX_Size() int

func (*SegmentID) XXX_Unmarshal 

func (m *SegmentID) XXX_Unmarshal(b []byte) error

type StreamID 

type StreamID struct {
	Bucket               []byte                   `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	EncryptedObjectKey   []byte                   `protobuf:"bytes,2,opt,name=encrypted_object_key,json=encryptedObjectKey,proto3" json:"encrypted_object_key,omitempty"`
	Version              int64                    `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	EncryptionParameters *pb.EncryptionParameters `protobuf:"bytes,12,opt,name=encryption_parameters,json=encryptionParameters,proto3" json:"encryption_parameters,omitempty"`
	CreationDate         time.Time                `protobuf:"bytes,5,opt,name=creation_date,json=creationDate,proto3,stdtime" json:"creation_date"`
	ExpirationDate       time.Time                `protobuf:"bytes,6,opt,name=expiration_date,json=expirationDate,proto3,stdtime" json:"expiration_date"`
	MultipartObject      bool                     `protobuf:"varint,11,opt,name=multipart_object,json=multipartObject,proto3" json:"multipart_object,omitempty"`
	SatelliteSignature   []byte                   `protobuf:"bytes,9,opt,name=satellite_signature,json=satelliteSignature,proto3" json:"satellite_signature,omitempty"`
	StreamId             []byte                   `protobuf:"bytes,10,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Placement            int32                    `protobuf:"varint,13,opt,name=placement,proto3" json:"placement,omitempty"`
	Versioned            bool                     `protobuf:"varint,15,opt,name=versioned,proto3" json:"versioned,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*StreamID) Descriptor 

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

func (*StreamID) GetBucket 

func (m *StreamID) GetBucket() []byte

func (*StreamID) GetCreationDate 

func (m *StreamID) GetCreationDate() time.Time

func (*StreamID) GetEncryptedObjectKey added in v1.41.1 

func (m *StreamID) GetEncryptedObjectKey() []byte

func (*StreamID) GetEncryptionParameters added in v1.26.2 

func (m *StreamID) GetEncryptionParameters() *pb.EncryptionParameters

func (*StreamID) GetExpirationDate 

func (m *StreamID) GetExpirationDate() time.Time

func (*StreamID) GetMultipartObject added in v1.26.2 

func (m *StreamID) GetMultipartObject() bool

func (*StreamID) GetPlacement added in v1.44.1 

func (m *StreamID) GetPlacement() int32

func (*StreamID) GetSatelliteSignature 

func (m *StreamID) GetSatelliteSignature() []byte

func (*StreamID) GetStreamId 

func (m *StreamID) GetStreamId() []byte

func (*StreamID) GetVersion 

func (m *StreamID) GetVersion() int64

func (*StreamID) GetVersioned added in v1.93.1 

func (m *StreamID) GetVersioned() bool

func (*StreamID) ProtoMessage 

func (*StreamID) ProtoMessage()

func (*StreamID) Reset 

func (m *StreamID) Reset()

func (*StreamID) String 

func (m *StreamID) String() string

func (*StreamID) XXX_DiscardUnknown 

func (m *StreamID) XXX_DiscardUnknown()

func (*StreamID) XXX_Marshal 

func (m *StreamID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamID) XXX_Merge 

func (m *StreamID) XXX_Merge(src proto.Message)

func (*StreamID) XXX_Size 

func (m *StreamID) XXX_Size() int

func (*StreamID) XXX_Unmarshal 

func (m *StreamID) XXX_Unmarshal(b []byte) error

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.