hydra_api

package
v0.51.5 Latest Latest
Warning

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

 Go to latest Published: May 10, 2026 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const SRPCHydraDaemonServiceServiceID = "hydra.api.HydraDaemonService"

Variables

View Source 
var (
	BucketOp_name = map[int32]string{
		0: "BucketOp_UNKNOWN",
		1: "BucketOp_BLOCK_GET",
		2: "BucketOp_BLOCK_PUT",
		3: "BucketOp_BLOCK_RM",
	}
	BucketOp_value = map[string]int32{
		"BucketOp_UNKNOWN":   0,
		"BucketOp_BLOCK_GET": 1,
		"BucketOp_BLOCK_PUT": 2,
		"BucketOp_BLOCK_RM":  3,
	}
)

Enum value maps for BucketOp.

View Source 
var (
	ObjectStoreOp_name = map[int32]string{
		0: "ObjectStoreOp_UNKNOWN",
		1: "ObjectStoreOp_GET_KEY",
		2: "ObjectStoreOp_PUT_KEY",
		3: "ObjectStoreOp_LIST_KEYS",
		4: "ObjectStoreOp_DELETE_KEY",
	}
	ObjectStoreOp_value = map[string]int32{
		"ObjectStoreOp_UNKNOWN":    0,
		"ObjectStoreOp_GET_KEY":    1,
		"ObjectStoreOp_PUT_KEY":    2,
		"ObjectStoreOp_LIST_KEYS":  3,
		"ObjectStoreOp_DELETE_KEY": 4,
	}
)

Enum value maps for ObjectStoreOp.

Functions

func NewSRPCHydraDaemonServiceHandler 

func NewSRPCHydraDaemonServiceHandler(impl SRPCHydraDaemonServiceServer, serviceID string) srpc.Handler

NewSRPCHydraDaemonServiceHandler constructs a new RPC handler. serviceID: if empty, uses default: hydra.api.HydraDaemonService

func SRPCRegisterHydraDaemonService 

func SRPCRegisterHydraDaemonService(mux srpc.Mux, impl SRPCHydraDaemonServiceServer) error

SRPCRegisterHydraDaemonService registers the implementation with the mux. Uses the default serviceID: hydra.api.HydraDaemonService

Types

type API 

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

API implements the daemon API.

func NewAPI 

func NewAPI(bus bus.Bus, conf *Config) (*API, error)

NewAPI constructs a new instance of the API.

func (*API) ApplyBucketConfig 

func (a *API) ApplyBucketConfig(
	req *ApplyBucketConfigRequest,
	serv SRPCHydraDaemonService_ApplyBucketConfigStream,
) error

ApplyBucketConfig requests the system ingest a bucket config.

func (*API) BucketOp 

func (a *API) BucketOp(
	ctx context.Context,
	req *BucketOpRequest,
) (*BucketOpResponse, error)

BucketOp performs a bucket operation.

func (*API) ListBuckets 

func (a *API) ListBuckets(
	ctx context.Context,
	req *volume.ListBucketsRequest,
) (*ListBucketsResponse, error)

ListBuckets lists basic bucket information

func (*API) ListVolumes 

func (a *API) ListVolumes(
	ctx context.Context,
	req *ListVolumesRequest,
) (*ListVolumesResponse, error)

ListVolumes lists basic volume information

func (*API) ObjectStoreOp 

func (a *API) ObjectStoreOp(
	ctx context.Context,
	req *ObjectStoreOpRequest,
) (*ObjectStoreOpResponse, error)

ObjectStoreOp performs an object store operation.

func (*API) RegisterAsSRPCServer 

func (a *API) RegisterAsSRPCServer(mux srpc.Mux)

RegisterAsSRPCServer registers the API to the mux.

type ApplyBucketConfigRequest 

type ApplyBucketConfigRequest struct {

	// Config is the bucket config.
	Config *bucket.Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// VolumeIdRe is a regex string to match volume IDs.
	// Set to '.*' to match all volumes.
	// If empty, will update volumes that already have the config only.
	// If VolumeIDList is set, it will override this field.
	// Cannot be specified if VolumeIDList is set.
	VolumeIdRe string `protobuf:"bytes,2,opt,name=volume_id_re,json=volumeIdRe,proto3" json:"volumeIdRe,omitempty"`
	// VolumeIdList is a list of volume IDs to match.
	// Cannot be specified if VolumeIDRe is set.
	VolumeIdList []string `protobuf:"bytes,3,rep,name=volume_id_list,json=volumeIdList,proto3" json:"volumeIdList,omitempty"`
	// contains filtered or unexported fields
}

ApplyBucketConfigRequest requests to apply a bucket config to volumes.

func (*ApplyBucketConfigRequest) CloneMessageVT 

func (m *ApplyBucketConfigRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ApplyBucketConfigRequest) CloneVT 

func (m *ApplyBucketConfigRequest) CloneVT() *ApplyBucketConfigRequest

func (*ApplyBucketConfigRequest) EqualMessageVT 

func (this *ApplyBucketConfigRequest) EqualMessageVT(thatMsg any) bool

func (*ApplyBucketConfigRequest) EqualVT 

func (this *ApplyBucketConfigRequest) EqualVT(that *ApplyBucketConfigRequest) bool

func (*ApplyBucketConfigRequest) GetConfig 

func (x *ApplyBucketConfigRequest) GetConfig() *bucket.Config

func (*ApplyBucketConfigRequest) GetVolumeIdList 

func (x *ApplyBucketConfigRequest) GetVolumeIdList() []string

func (*ApplyBucketConfigRequest) GetVolumeIdRe 

func (x *ApplyBucketConfigRequest) GetVolumeIdRe() string

func (*ApplyBucketConfigRequest) MarshalJSON 

func (x *ApplyBucketConfigRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ApplyBucketConfigRequest to JSON.

func (*ApplyBucketConfigRequest) MarshalProtoJSON 

func (x *ApplyBucketConfigRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ApplyBucketConfigRequest message to JSON.

func (*ApplyBucketConfigRequest) MarshalProtoText 

func (x *ApplyBucketConfigRequest) MarshalProtoText() string

func (*ApplyBucketConfigRequest) MarshalToSizedBufferVT 

func (m *ApplyBucketConfigRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ApplyBucketConfigRequest) MarshalToVT 

func (m *ApplyBucketConfigRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ApplyBucketConfigRequest) MarshalVT 

func (m *ApplyBucketConfigRequest) MarshalVT() (dAtA []byte, err error)

func (*ApplyBucketConfigRequest) ParseVolumeIdRe 

func (r *ApplyBucketConfigRequest) ParseVolumeIdRe() (*regexp.Regexp, error)

ParseVolumeIdRe parses the volume id regex field. Returns nil if the field was empty.

func (*ApplyBucketConfigRequest) ProtoMessage 

func (*ApplyBucketConfigRequest) ProtoMessage()

func (*ApplyBucketConfigRequest) Reset 

func (x *ApplyBucketConfigRequest) Reset()

func (*ApplyBucketConfigRequest) SizeVT 

func (m *ApplyBucketConfigRequest) SizeVT() (n int)

func (*ApplyBucketConfigRequest) String 

func (x *ApplyBucketConfigRequest) String() string

func (*ApplyBucketConfigRequest) ToApplyBucketConfig 

func (r *ApplyBucketConfigRequest) ToApplyBucketConfig() (bucket.ApplyBucketConfig, error)

ToApplyBucketConfig builds an ApplyBucketConfig directive.

func (*ApplyBucketConfigRequest) UnmarshalJSON 

func (x *ApplyBucketConfigRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ApplyBucketConfigRequest from JSON.

func (*ApplyBucketConfigRequest) UnmarshalProtoJSON 

func (x *ApplyBucketConfigRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ApplyBucketConfigRequest message from JSON.

func (*ApplyBucketConfigRequest) UnmarshalVT 

func (m *ApplyBucketConfigRequest) UnmarshalVT(dAtA []byte) error

func (*ApplyBucketConfigRequest) Validate 

func (r *ApplyBucketConfigRequest) Validate() error

Validate validates the request.

type ApplyBucketConfigResponse 

type ApplyBucketConfigResponse struct {

	// ApplyConfResult is a result value for the application.
	ApplyConfResult *bucket.ApplyBucketConfigResult `protobuf:"bytes,1,opt,name=apply_conf_result,json=applyConfResult,proto3" json:"applyConfResult,omitempty"`
	// contains filtered or unexported fields
}

ApplyBucketConfigResponse returns results of the request.

func (*ApplyBucketConfigResponse) CloneMessageVT 

func (m *ApplyBucketConfigResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ApplyBucketConfigResponse) CloneVT 

func (m *ApplyBucketConfigResponse) CloneVT() *ApplyBucketConfigResponse

func (*ApplyBucketConfigResponse) EqualMessageVT 

func (this *ApplyBucketConfigResponse) EqualMessageVT(thatMsg any) bool

func (*ApplyBucketConfigResponse) EqualVT 

func (this *ApplyBucketConfigResponse) EqualVT(that *ApplyBucketConfigResponse) bool

func (*ApplyBucketConfigResponse) GetApplyConfResult 

func (x *ApplyBucketConfigResponse) GetApplyConfResult() *bucket.ApplyBucketConfigResult

func (*ApplyBucketConfigResponse) MarshalJSON 

func (x *ApplyBucketConfigResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ApplyBucketConfigResponse to JSON.

func (*ApplyBucketConfigResponse) MarshalProtoJSON 

func (x *ApplyBucketConfigResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ApplyBucketConfigResponse message to JSON.

func (*ApplyBucketConfigResponse) MarshalProtoText 

func (x *ApplyBucketConfigResponse) MarshalProtoText() string

func (*ApplyBucketConfigResponse) MarshalToSizedBufferVT 

func (m *ApplyBucketConfigResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ApplyBucketConfigResponse) MarshalToVT 

func (m *ApplyBucketConfigResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ApplyBucketConfigResponse) MarshalVT 

func (m *ApplyBucketConfigResponse) MarshalVT() (dAtA []byte, err error)

func (*ApplyBucketConfigResponse) ProtoMessage 

func (*ApplyBucketConfigResponse) ProtoMessage()

func (*ApplyBucketConfigResponse) Reset 

func (x *ApplyBucketConfigResponse) Reset()

func (*ApplyBucketConfigResponse) SizeVT 

func (m *ApplyBucketConfigResponse) SizeVT() (n int)

func (*ApplyBucketConfigResponse) String 

func (x *ApplyBucketConfigResponse) String() string

func (*ApplyBucketConfigResponse) UnmarshalJSON 

func (x *ApplyBucketConfigResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ApplyBucketConfigResponse from JSON.

func (*ApplyBucketConfigResponse) UnmarshalProtoJSON 

func (x *ApplyBucketConfigResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ApplyBucketConfigResponse message from JSON.

func (*ApplyBucketConfigResponse) UnmarshalVT 

func (m *ApplyBucketConfigResponse) UnmarshalVT(dAtA []byte) error

type BucketOp 

type BucketOp int32

BucketOp is a bucket operation. 

const (
	BucketOp_BucketOp_UNKNOWN   BucketOp = 0
	BucketOp_BucketOp_BLOCK_GET BucketOp = 1
	BucketOp_BucketOp_BLOCK_PUT BucketOp = 2
	BucketOp_BucketOp_BLOCK_RM  BucketOp = 3
)

func (BucketOp) Enum 

func (x BucketOp) Enum() *BucketOp

func (BucketOp) MarshalJSON 

func (x BucketOp) MarshalJSON() ([]byte, error)

MarshalJSON marshals the BucketOp to JSON.

func (BucketOp) MarshalProtoJSON 

func (x BucketOp) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the BucketOp to JSON.

func (BucketOp) MarshalProtoText 

func (x BucketOp) MarshalProtoText() string

func (BucketOp) MarshalText 

func (x BucketOp) MarshalText() ([]byte, error)

MarshalText marshals the BucketOp to text.

func (BucketOp) String 

func (x BucketOp) String() string

func (*BucketOp) UnmarshalJSON 

func (x *BucketOp) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the BucketOp from JSON.

func (*BucketOp) UnmarshalProtoJSON 

func (x *BucketOp) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the BucketOp from JSON.

func (*BucketOp) UnmarshalText 

func (x *BucketOp) UnmarshalText(b []byte) error

UnmarshalText unmarshals the BucketOp from text.

func (BucketOp) Validate 

func (op BucketOp) Validate() error

Validate validates the operation code. Unknown is considered valid.

type BucketOpRequest 

type BucketOpRequest struct {

	// Op is the operation to perform against the bucket.
	Op BucketOp `protobuf:"varint,1,opt,name=op,proto3" json:"op,omitempty"`
	// BucketOpArgs are common bucket operation arguments.
	BucketOpArgs *bucket.BucketOpArgs `protobuf:"bytes,2,opt,name=bucket_op_args,json=bucketOpArgs,proto3" json:"bucketOpArgs,omitempty"`
	// BlockRef is the block ref to lookup.
	// Used when op == BLOCK_GET || op == BLOCK_RM
	BlockRef *block.BlockRef `protobuf:"bytes,3,opt,name=block_ref,json=blockRef,proto3" json:"blockRef,omitempty"`
	// PutOpts are overriding put options.
	// Defaults are specified by the bucket.
	// Used when op == BLOCK_PUT
	PutOpts *block.PutOpts `protobuf:"bytes,4,opt,name=put_opts,json=putOpts,proto3" json:"putOpts,omitempty"`
	// Data is the data to put in the block.
	// May be constrained by the bucket block size limit.
	// Used when op == BLOCK_PUT
	Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketOpRequest) CloneMessageVT 

func (m *BucketOpRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*BucketOpRequest) CloneVT 

func (m *BucketOpRequest) CloneVT() *BucketOpRequest

func (*BucketOpRequest) EqualMessageVT 

func (this *BucketOpRequest) EqualMessageVT(thatMsg any) bool

func (*BucketOpRequest) EqualVT 

func (this *BucketOpRequest) EqualVT(that *BucketOpRequest) bool

func (*BucketOpRequest) GetBlockRef 

func (x *BucketOpRequest) GetBlockRef() *block.BlockRef

func (*BucketOpRequest) GetBucketOpArgs 

func (x *BucketOpRequest) GetBucketOpArgs() *bucket.BucketOpArgs

func (*BucketOpRequest) GetData 

func (x *BucketOpRequest) GetData() []byte

func (*BucketOpRequest) GetOp 

func (x *BucketOpRequest) GetOp() BucketOp

func (*BucketOpRequest) GetPutOpts 

func (x *BucketOpRequest) GetPutOpts() *block.PutOpts

func (*BucketOpRequest) MarshalJSON 

func (x *BucketOpRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the BucketOpRequest to JSON.

func (*BucketOpRequest) MarshalProtoJSON 

func (x *BucketOpRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the BucketOpRequest message to JSON.

func (*BucketOpRequest) MarshalProtoText 

func (x *BucketOpRequest) MarshalProtoText() string

func (*BucketOpRequest) MarshalToSizedBufferVT 

func (m *BucketOpRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BucketOpRequest) MarshalToVT 

func (m *BucketOpRequest) MarshalToVT(dAtA []byte) (int, error)

func (*BucketOpRequest) MarshalVT 

func (m *BucketOpRequest) MarshalVT() (dAtA []byte, err error)

func (*BucketOpRequest) ProtoMessage 

func (*BucketOpRequest) ProtoMessage()

func (*BucketOpRequest) Reset 

func (x *BucketOpRequest) Reset()

func (*BucketOpRequest) SizeVT 

func (m *BucketOpRequest) SizeVT() (n int)

func (*BucketOpRequest) String 

func (x *BucketOpRequest) String() string

func (*BucketOpRequest) UnmarshalJSON 

func (x *BucketOpRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the BucketOpRequest from JSON.

func (*BucketOpRequest) UnmarshalProtoJSON 

func (x *BucketOpRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the BucketOpRequest message from JSON.

func (*BucketOpRequest) UnmarshalVT 

func (m *BucketOpRequest) UnmarshalVT(dAtA []byte) error

func (*BucketOpRequest) Validate 

func (r *BucketOpRequest) Validate() error

Validate validates the request.

type BucketOpResponse 

type BucketOpResponse struct {

	// Event is the bucket event, if any.
	// Used when op == BLOCK_PUT
	Event *event.Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// Data is the returned data, if any.
	// Used when op == BLOCK_GET
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// Found indicates if the data field is filled.
	// Used when op == BLOCK_GET
	Found bool `protobuf:"varint,3,opt,name=found,proto3" json:"found,omitempty"`
	// contains filtered or unexported fields
}

BucketOpResponse is the response type for BucketOp.

func (*BucketOpResponse) CloneMessageVT 

func (m *BucketOpResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*BucketOpResponse) CloneVT 

func (m *BucketOpResponse) CloneVT() *BucketOpResponse

func (*BucketOpResponse) EqualMessageVT 

func (this *BucketOpResponse) EqualMessageVT(thatMsg any) bool

func (*BucketOpResponse) EqualVT 

func (this *BucketOpResponse) EqualVT(that *BucketOpResponse) bool

func (*BucketOpResponse) GetData 

func (x *BucketOpResponse) GetData() []byte

func (*BucketOpResponse) GetEvent 

func (x *BucketOpResponse) GetEvent() *event.Event

func (*BucketOpResponse) GetFound 

func (x *BucketOpResponse) GetFound() bool

func (*BucketOpResponse) MarshalJSON 

func (x *BucketOpResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the BucketOpResponse to JSON.

func (*BucketOpResponse) MarshalProtoJSON 

func (x *BucketOpResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the BucketOpResponse message to JSON.

func (*BucketOpResponse) MarshalProtoText 

func (x *BucketOpResponse) MarshalProtoText() string

func (*BucketOpResponse) MarshalToSizedBufferVT 

func (m *BucketOpResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*BucketOpResponse) MarshalToVT 

func (m *BucketOpResponse) MarshalToVT(dAtA []byte) (int, error)

func (*BucketOpResponse) MarshalVT 

func (m *BucketOpResponse) MarshalVT() (dAtA []byte, err error)

func (*BucketOpResponse) ProtoMessage 

func (*BucketOpResponse) ProtoMessage()

func (*BucketOpResponse) Reset 

func (x *BucketOpResponse) Reset()

func (*BucketOpResponse) SizeVT 

func (m *BucketOpResponse) SizeVT() (n int)

func (*BucketOpResponse) String 

func (x *BucketOpResponse) String() string

func (*BucketOpResponse) UnmarshalJSON 

func (x *BucketOpResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the BucketOpResponse from JSON.

func (*BucketOpResponse) UnmarshalProtoJSON 

func (x *BucketOpResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the BucketOpResponse message from JSON.

func (*BucketOpResponse) UnmarshalVT 

func (m *BucketOpResponse) UnmarshalVT(dAtA []byte) error

type Config 

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

Config is hydra api configuration.

func (*Config) CloneMessageVT 

func (m *Config) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*Config) CloneVT 

func (m *Config) CloneVT() *Config

func (*Config) EqualMessageVT 

func (this *Config) EqualMessageVT(thatMsg any) bool

func (*Config) EqualVT 

func (this *Config) EqualVT(that *Config) bool

func (*Config) MarshalJSON 

func (x *Config) MarshalJSON() ([]byte, error)

MarshalJSON marshals the Config to JSON.

func (*Config) MarshalProtoJSON 

func (x *Config) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the Config message to JSON.

func (*Config) MarshalProtoText 

func (x *Config) MarshalProtoText() string

func (*Config) MarshalToSizedBufferVT 

func (m *Config) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Config) MarshalToVT 

func (m *Config) MarshalToVT(dAtA []byte) (int, error)

func (*Config) MarshalVT 

func (m *Config) MarshalVT() (dAtA []byte, err error)

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) SizeVT 

func (m *Config) SizeVT() (n int)

func (*Config) String 

func (x *Config) String() string

func (*Config) UnmarshalJSON 

func (x *Config) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the Config from JSON.

func (*Config) UnmarshalProtoJSON 

func (x *Config) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the Config message from JSON.

func (*Config) UnmarshalVT 

func (m *Config) UnmarshalVT(dAtA []byte) error

type HydraDaemonClient 

type HydraDaemonClient interface {
	SRPCHydraDaemonServiceClient
	bifrost_api.BifrostAPIClient
}

HydraDaemonClient has all services provided by the daemon.

func NewHydraDaemonClient 

func NewHydraDaemonClient(cc srpc.Client) HydraDaemonClient

NewHydraDaemonClient constructs a new hydra daemon client.

type ListBucketsResponse 

type ListBucketsResponse struct {

	// Buckets is the list of buckets returned from the request.
	Buckets []*volume.VolumeBucketInfo `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
	// contains filtered or unexported fields
}

ListBucketsResponse returns buckets.

func (*ListBucketsResponse) CloneMessageVT 

func (m *ListBucketsResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ListBucketsResponse) CloneVT 

func (m *ListBucketsResponse) CloneVT() *ListBucketsResponse

func (*ListBucketsResponse) EqualMessageVT 

func (this *ListBucketsResponse) EqualMessageVT(thatMsg any) bool

func (*ListBucketsResponse) EqualVT 

func (this *ListBucketsResponse) EqualVT(that *ListBucketsResponse) bool

func (*ListBucketsResponse) GetBuckets 

func (x *ListBucketsResponse) GetBuckets() []*volume.VolumeBucketInfo

func (*ListBucketsResponse) MarshalJSON 

func (x *ListBucketsResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ListBucketsResponse to JSON.

func (*ListBucketsResponse) MarshalProtoJSON 

func (x *ListBucketsResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ListBucketsResponse message to JSON.

func (*ListBucketsResponse) MarshalProtoText 

func (x *ListBucketsResponse) MarshalProtoText() string

func (*ListBucketsResponse) MarshalToSizedBufferVT 

func (m *ListBucketsResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListBucketsResponse) MarshalToVT 

func (m *ListBucketsResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ListBucketsResponse) MarshalVT 

func (m *ListBucketsResponse) MarshalVT() (dAtA []byte, err error)

func (*ListBucketsResponse) ProtoMessage 

func (*ListBucketsResponse) ProtoMessage()

func (*ListBucketsResponse) Reset 

func (x *ListBucketsResponse) Reset()

func (*ListBucketsResponse) SizeVT 

func (m *ListBucketsResponse) SizeVT() (n int)

func (*ListBucketsResponse) String 

func (x *ListBucketsResponse) String() string

func (*ListBucketsResponse) UnmarshalJSON 

func (x *ListBucketsResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ListBucketsResponse from JSON.

func (*ListBucketsResponse) UnmarshalProtoJSON 

func (x *ListBucketsResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ListBucketsResponse message from JSON.

func (*ListBucketsResponse) UnmarshalVT 

func (m *ListBucketsResponse) UnmarshalVT(dAtA []byte) error

type ListVolumesRequest 

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

ListVolumesRequest looks up volumes.

func (*ListVolumesRequest) CloneMessageVT 

func (m *ListVolumesRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ListVolumesRequest) CloneVT 

func (m *ListVolumesRequest) CloneVT() *ListVolumesRequest

func (*ListVolumesRequest) EqualMessageVT 

func (this *ListVolumesRequest) EqualMessageVT(thatMsg any) bool

func (*ListVolumesRequest) EqualVT 

func (this *ListVolumesRequest) EqualVT(that *ListVolumesRequest) bool

func (*ListVolumesRequest) MarshalJSON 

func (x *ListVolumesRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ListVolumesRequest to JSON.

func (*ListVolumesRequest) MarshalProtoJSON 

func (x *ListVolumesRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ListVolumesRequest message to JSON.

func (*ListVolumesRequest) MarshalProtoText 

func (x *ListVolumesRequest) MarshalProtoText() string

func (*ListVolumesRequest) MarshalToSizedBufferVT 

func (m *ListVolumesRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListVolumesRequest) MarshalToVT 

func (m *ListVolumesRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ListVolumesRequest) MarshalVT 

func (m *ListVolumesRequest) MarshalVT() (dAtA []byte, err error)

func (*ListVolumesRequest) ProtoMessage 

func (*ListVolumesRequest) ProtoMessage()

func (*ListVolumesRequest) Reset 

func (x *ListVolumesRequest) Reset()

func (*ListVolumesRequest) SizeVT 

func (m *ListVolumesRequest) SizeVT() (n int)

func (*ListVolumesRequest) String 

func (x *ListVolumesRequest) String() string

func (*ListVolumesRequest) UnmarshalJSON 

func (x *ListVolumesRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ListVolumesRequest from JSON.

func (*ListVolumesRequest) UnmarshalProtoJSON 

func (x *ListVolumesRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ListVolumesRequest message from JSON.

func (*ListVolumesRequest) UnmarshalVT 

func (m *ListVolumesRequest) UnmarshalVT(dAtA []byte) error

type ListVolumesResponse 

type ListVolumesResponse struct {

	// Volumes is the list of volumes returned from the request.
	Volumes []*volume.VolumeInfo `protobuf:"bytes,1,rep,name=volumes,proto3" json:"volumes,omitempty"`
	// contains filtered or unexported fields
}

ListVolumesResponse returns volumes.

func (*ListVolumesResponse) CloneMessageVT 

func (m *ListVolumesResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ListVolumesResponse) CloneVT 

func (m *ListVolumesResponse) CloneVT() *ListVolumesResponse

func (*ListVolumesResponse) EqualMessageVT 

func (this *ListVolumesResponse) EqualMessageVT(thatMsg any) bool

func (*ListVolumesResponse) EqualVT 

func (this *ListVolumesResponse) EqualVT(that *ListVolumesResponse) bool

func (*ListVolumesResponse) GetVolumes 

func (x *ListVolumesResponse) GetVolumes() []*volume.VolumeInfo

func (*ListVolumesResponse) MarshalJSON 

func (x *ListVolumesResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ListVolumesResponse to JSON.

func (*ListVolumesResponse) MarshalProtoJSON 

func (x *ListVolumesResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ListVolumesResponse message to JSON.

func (*ListVolumesResponse) MarshalProtoText 

func (x *ListVolumesResponse) MarshalProtoText() string

func (*ListVolumesResponse) MarshalToSizedBufferVT 

func (m *ListVolumesResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ListVolumesResponse) MarshalToVT 

func (m *ListVolumesResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ListVolumesResponse) MarshalVT 

func (m *ListVolumesResponse) MarshalVT() (dAtA []byte, err error)

func (*ListVolumesResponse) ProtoMessage 

func (*ListVolumesResponse) ProtoMessage()

func (*ListVolumesResponse) Reset 

func (x *ListVolumesResponse) Reset()

func (*ListVolumesResponse) SizeVT 

func (m *ListVolumesResponse) SizeVT() (n int)

func (*ListVolumesResponse) String 

func (x *ListVolumesResponse) String() string

func (*ListVolumesResponse) UnmarshalJSON 

func (x *ListVolumesResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ListVolumesResponse from JSON.

func (*ListVolumesResponse) UnmarshalProtoJSON 

func (x *ListVolumesResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ListVolumesResponse message from JSON.

func (*ListVolumesResponse) UnmarshalVT 

func (m *ListVolumesResponse) UnmarshalVT(dAtA []byte) error

type ObjectStoreOp 

type ObjectStoreOp int32

ObjectStoreOp is a object store operation. 

const (
	ObjectStoreOp_ObjectStoreOp_UNKNOWN ObjectStoreOp = 0
	// ObjectStoreOp_GET_KEY gets a key.
	ObjectStoreOp_ObjectStoreOp_GET_KEY ObjectStoreOp = 1
	// ObjectStoreOp_PUT_KEY sets a key.
	ObjectStoreOp_ObjectStoreOp_PUT_KEY ObjectStoreOp = 2
	// ObjectStoreOp_LIST_KEYS lists keys by a prefix.
	ObjectStoreOp_ObjectStoreOp_LIST_KEYS ObjectStoreOp = 3
	// ObjectStoreOp_DELETE_KEY deletes a key.
	ObjectStoreOp_ObjectStoreOp_DELETE_KEY ObjectStoreOp = 4
)

func (ObjectStoreOp) Enum 

func (x ObjectStoreOp) Enum() *ObjectStoreOp

func (ObjectStoreOp) MarshalJSON 

func (x ObjectStoreOp) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ObjectStoreOp to JSON.

func (ObjectStoreOp) MarshalProtoJSON 

func (x ObjectStoreOp) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ObjectStoreOp to JSON.

func (ObjectStoreOp) MarshalProtoText 

func (x ObjectStoreOp) MarshalProtoText() string

func (ObjectStoreOp) MarshalText 

func (x ObjectStoreOp) MarshalText() ([]byte, error)

MarshalText marshals the ObjectStoreOp to text.

func (ObjectStoreOp) String 

func (x ObjectStoreOp) String() string

func (*ObjectStoreOp) UnmarshalJSON 

func (x *ObjectStoreOp) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ObjectStoreOp from JSON.

func (*ObjectStoreOp) UnmarshalProtoJSON 

func (x *ObjectStoreOp) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ObjectStoreOp from JSON.

func (*ObjectStoreOp) UnmarshalText 

func (x *ObjectStoreOp) UnmarshalText(b []byte) error

UnmarshalText unmarshals the ObjectStoreOp from text.

func (ObjectStoreOp) Validate 

func (op ObjectStoreOp) Validate() error

Validate validates the operation code.

type ObjectStoreOpRequest 

type ObjectStoreOpRequest struct {

	// Op is the operation to perform against the bucket.
	Op ObjectStoreOp `protobuf:"varint,1,opt,name=op,proto3" json:"op,omitempty"`
	// VolumeId is the volume id.
	VolumeId string `protobuf:"bytes,2,opt,name=volume_id,json=volumeId,proto3" json:"volumeId,omitempty"`
	// StoreName is the object store name.
	StoreName string `protobuf:"bytes,3,opt,name=store_name,json=storeName,proto3" json:"storeName,omitempty"`
	// Key is the key to get, put, or delete.
	// Field is the prefix if a list request.
	Key string `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	// Data is the data to put.
	// May be constrained by a size limit.
	// Used when op == PUT_KEY
	Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

ObjectStoreOpRequest is the object store operation request.

func (*ObjectStoreOpRequest) CloneMessageVT 

func (m *ObjectStoreOpRequest) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ObjectStoreOpRequest) CloneVT 

func (m *ObjectStoreOpRequest) CloneVT() *ObjectStoreOpRequest

func (*ObjectStoreOpRequest) EqualMessageVT 

func (this *ObjectStoreOpRequest) EqualMessageVT(thatMsg any) bool

func (*ObjectStoreOpRequest) EqualVT 

func (this *ObjectStoreOpRequest) EqualVT(that *ObjectStoreOpRequest) bool

func (*ObjectStoreOpRequest) GetData 

func (x *ObjectStoreOpRequest) GetData() []byte

func (*ObjectStoreOpRequest) GetKey 

func (x *ObjectStoreOpRequest) GetKey() string

func (*ObjectStoreOpRequest) GetOp 

func (x *ObjectStoreOpRequest) GetOp() ObjectStoreOp

func (*ObjectStoreOpRequest) GetStoreName 

func (x *ObjectStoreOpRequest) GetStoreName() string

func (*ObjectStoreOpRequest) GetVolumeId 

func (x *ObjectStoreOpRequest) GetVolumeId() string

func (*ObjectStoreOpRequest) MarshalJSON 

func (x *ObjectStoreOpRequest) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ObjectStoreOpRequest to JSON.

func (*ObjectStoreOpRequest) MarshalProtoJSON 

func (x *ObjectStoreOpRequest) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ObjectStoreOpRequest message to JSON.

func (*ObjectStoreOpRequest) MarshalProtoText 

func (x *ObjectStoreOpRequest) MarshalProtoText() string

func (*ObjectStoreOpRequest) MarshalToSizedBufferVT 

func (m *ObjectStoreOpRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ObjectStoreOpRequest) MarshalToVT 

func (m *ObjectStoreOpRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ObjectStoreOpRequest) MarshalVT 

func (m *ObjectStoreOpRequest) MarshalVT() (dAtA []byte, err error)

func (*ObjectStoreOpRequest) ProtoMessage 

func (*ObjectStoreOpRequest) ProtoMessage()

func (*ObjectStoreOpRequest) Reset 

func (x *ObjectStoreOpRequest) Reset()

func (*ObjectStoreOpRequest) SizeVT 

func (m *ObjectStoreOpRequest) SizeVT() (n int)

func (*ObjectStoreOpRequest) String 

func (x *ObjectStoreOpRequest) String() string

func (*ObjectStoreOpRequest) UnmarshalJSON 

func (x *ObjectStoreOpRequest) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ObjectStoreOpRequest from JSON.

func (*ObjectStoreOpRequest) UnmarshalProtoJSON 

func (x *ObjectStoreOpRequest) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ObjectStoreOpRequest message from JSON.

func (*ObjectStoreOpRequest) UnmarshalVT 

func (m *ObjectStoreOpRequest) UnmarshalVT(dAtA []byte) error

func (*ObjectStoreOpRequest) Validate 

func (r *ObjectStoreOpRequest) Validate() error

Validate validates the request.

type ObjectStoreOpResponse 

type ObjectStoreOpResponse struct {

	// Data is the returned data, if any.
	// Used when op == BLOCK_GET
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// Found indicates if the data field is filled.
	// Used when op == BLOCK_GET
	Found bool `protobuf:"varint,2,opt,name=found,proto3" json:"found,omitempty"`
	// Keys are the output keys from the list call.
	Keys [][]byte `protobuf:"bytes,3,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

ObjectStoreOpResponse is the response type for ObjectStoreOp.

func (*ObjectStoreOpResponse) CloneMessageVT 

func (m *ObjectStoreOpResponse) CloneMessageVT() protobuf_go_lite.CloneMessage

func (*ObjectStoreOpResponse) CloneVT 

func (m *ObjectStoreOpResponse) CloneVT() *ObjectStoreOpResponse

func (*ObjectStoreOpResponse) EqualMessageVT 

func (this *ObjectStoreOpResponse) EqualMessageVT(thatMsg any) bool

func (*ObjectStoreOpResponse) EqualVT 

func (this *ObjectStoreOpResponse) EqualVT(that *ObjectStoreOpResponse) bool

func (*ObjectStoreOpResponse) GetData 

func (x *ObjectStoreOpResponse) GetData() []byte

func (*ObjectStoreOpResponse) GetFound 

func (x *ObjectStoreOpResponse) GetFound() bool

func (*ObjectStoreOpResponse) GetKeys 

func (x *ObjectStoreOpResponse) GetKeys() [][]byte

func (*ObjectStoreOpResponse) MarshalJSON 

func (x *ObjectStoreOpResponse) MarshalJSON() ([]byte, error)

MarshalJSON marshals the ObjectStoreOpResponse to JSON.

func (*ObjectStoreOpResponse) MarshalProtoJSON 

func (x *ObjectStoreOpResponse) MarshalProtoJSON(s *json.MarshalState)

MarshalProtoJSON marshals the ObjectStoreOpResponse message to JSON.

func (*ObjectStoreOpResponse) MarshalProtoText 

func (x *ObjectStoreOpResponse) MarshalProtoText() string

func (*ObjectStoreOpResponse) MarshalToSizedBufferVT 

func (m *ObjectStoreOpResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ObjectStoreOpResponse) MarshalToVT 

func (m *ObjectStoreOpResponse) MarshalToVT(dAtA []byte) (int, error)

func (*ObjectStoreOpResponse) MarshalVT 

func (m *ObjectStoreOpResponse) MarshalVT() (dAtA []byte, err error)

func (*ObjectStoreOpResponse) ProtoMessage 

func (*ObjectStoreOpResponse) ProtoMessage()

func (*ObjectStoreOpResponse) Reset 

func (x *ObjectStoreOpResponse) Reset()

func (*ObjectStoreOpResponse) SizeVT 

func (m *ObjectStoreOpResponse) SizeVT() (n int)

func (*ObjectStoreOpResponse) String 

func (x *ObjectStoreOpResponse) String() string

func (*ObjectStoreOpResponse) UnmarshalJSON 

func (x *ObjectStoreOpResponse) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals the ObjectStoreOpResponse from JSON.

func (*ObjectStoreOpResponse) UnmarshalProtoJSON 

func (x *ObjectStoreOpResponse) UnmarshalProtoJSON(s *json.UnmarshalState)

UnmarshalProtoJSON unmarshals the ObjectStoreOpResponse message from JSON.

func (*ObjectStoreOpResponse) UnmarshalVT 

func (m *ObjectStoreOpResponse) UnmarshalVT(dAtA []byte) error

type SRPCHydraDaemonServiceClient 

type SRPCHydraDaemonServiceClient interface {
	// SRPCClient returns the underlying SRPC client.
	SRPCClient() srpc.Client

	// ListVolumes lists volumes by the daemon.
	ListVolumes(ctx context.Context, in *ListVolumesRequest) (*ListVolumesResponse, error)
	// ListBuckets lists buckets by the daemon.
	ListBuckets(ctx context.Context, in *volume.ListBucketsRequest) (*ListBucketsResponse, error)
	// ApplyBucketConfig applies a bucket config to volumes.
	ApplyBucketConfig(ctx context.Context, in *ApplyBucketConfigRequest) (SRPCHydraDaemonService_ApplyBucketConfigClient, error)
	// BucketOp performs a bucket operation.
	BucketOp(ctx context.Context, in *BucketOpRequest) (*BucketOpResponse, error)
	// ObjectStoreOp performs an object store operation.
	ObjectStoreOp(ctx context.Context, in *ObjectStoreOpRequest) (*ObjectStoreOpResponse, error)
}

func NewSRPCHydraDaemonServiceClient 

func NewSRPCHydraDaemonServiceClient(cc srpc.Client) SRPCHydraDaemonServiceClient

func NewSRPCHydraDaemonServiceClientWithServiceID 

func NewSRPCHydraDaemonServiceClientWithServiceID(cc srpc.Client, serviceID string) SRPCHydraDaemonServiceClient

type SRPCHydraDaemonServiceHandler 

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

func (SRPCHydraDaemonServiceHandler) GetMethodIDs 

func (SRPCHydraDaemonServiceHandler) GetMethodIDs() []string

func (*SRPCHydraDaemonServiceHandler) GetServiceID 

func (d *SRPCHydraDaemonServiceHandler) GetServiceID() string

func (*SRPCHydraDaemonServiceHandler) InvokeMethod 

func (d *SRPCHydraDaemonServiceHandler) InvokeMethod(
	serviceID, methodID string,
	strm srpc.Stream,
) (bool, error)

func (SRPCHydraDaemonServiceHandler) InvokeMethod_ApplyBucketConfig 

func (SRPCHydraDaemonServiceHandler) InvokeMethod_ApplyBucketConfig(impl SRPCHydraDaemonServiceServer, strm srpc.Stream) error

func (SRPCHydraDaemonServiceHandler) InvokeMethod_BucketOp 

func (SRPCHydraDaemonServiceHandler) InvokeMethod_BucketOp(impl SRPCHydraDaemonServiceServer, strm srpc.Stream) error

func (SRPCHydraDaemonServiceHandler) InvokeMethod_ListBuckets 

func (SRPCHydraDaemonServiceHandler) InvokeMethod_ListBuckets(impl SRPCHydraDaemonServiceServer, strm srpc.Stream) error

func (SRPCHydraDaemonServiceHandler) InvokeMethod_ListVolumes 

func (SRPCHydraDaemonServiceHandler) InvokeMethod_ListVolumes(impl SRPCHydraDaemonServiceServer, strm srpc.Stream) error

func (SRPCHydraDaemonServiceHandler) InvokeMethod_ObjectStoreOp 

func (SRPCHydraDaemonServiceHandler) InvokeMethod_ObjectStoreOp(impl SRPCHydraDaemonServiceServer, strm srpc.Stream) error

type SRPCHydraDaemonServiceServer 

type SRPCHydraDaemonServiceServer interface {
	// ListVolumes lists volumes by the daemon.
	ListVolumes(context.Context, *ListVolumesRequest) (*ListVolumesResponse, error)
	// ListBuckets lists buckets by the daemon.
	ListBuckets(context.Context, *volume.ListBucketsRequest) (*ListBucketsResponse, error)
	// ApplyBucketConfig applies a bucket config to volumes.
	ApplyBucketConfig(*ApplyBucketConfigRequest, SRPCHydraDaemonService_ApplyBucketConfigStream) error
	// BucketOp performs a bucket operation.
	BucketOp(context.Context, *BucketOpRequest) (*BucketOpResponse, error)
	// ObjectStoreOp performs an object store operation.
	ObjectStoreOp(context.Context, *ObjectStoreOpRequest) (*ObjectStoreOpResponse, error)
}

type SRPCHydraDaemonService_ApplyBucketConfigClient 

type SRPCHydraDaemonService_ApplyBucketConfigClient interface {
	srpc.Stream
	Recv() (*ApplyBucketConfigResponse, error)
	RecvTo(*ApplyBucketConfigResponse) error
}

type SRPCHydraDaemonService_ApplyBucketConfigStream 

type SRPCHydraDaemonService_ApplyBucketConfigStream interface {
	srpc.Stream
	Send(*ApplyBucketConfigResponse) error
	SendAndClose(*ApplyBucketConfigResponse) error
}

type SRPCHydraDaemonService_BucketOpStream 

type SRPCHydraDaemonService_BucketOpStream interface {
	srpc.Stream
}

type SRPCHydraDaemonService_ListBucketsStream 

type SRPCHydraDaemonService_ListBucketsStream interface {
	srpc.Stream
}

type SRPCHydraDaemonService_ListVolumesStream 

type SRPCHydraDaemonService_ListVolumesStream interface {
	srpc.Stream
}

type SRPCHydraDaemonService_ObjectStoreOpStream 

type SRPCHydraDaemonService_ObjectStoreOpStream interface {
	srpc.Stream
}

Source Files

View all Source files

Directories

Path Synopsis

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.