api

package
v1.5.4-rc4 Latest Latest
Warning

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

Go to latest
Published: Feb 23, 2024 License: Apache-2.0 Imports: 3 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RPCToInstanceList added in v1.5.0

func RPCToInstanceList(obj *rpc.InstanceListResponse) map[string]*Instance

func RPCToProcessList

func RPCToProcessList(obj *rpc.ProcessListResponse) map[string]*Process

Types

type DiskInfo added in v1.5.0

type DiskInfo struct {
	ID          string
	UUID        string
	Path        string
	Type        string
	TotalSize   int64
	FreeSize    int64
	TotalBlocks int64
	FreeBlocks  int64
	BlockSize   int64
	ClusterSize int64
}

type EngineStream added in v1.5.0

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

func NewEngineStream added in v1.5.0

func NewEngineStream(stream spdkrpc.SPDKService_EngineWatchClient) *EngineStream

func (*EngineStream) Recv added in v1.5.0

func (s *EngineStream) Recv() (*empty.Empty, error)

type Instance added in v1.5.0

type Instance struct {
	Name               string         `json:"name"`
	Type               string         `json:"type"`
	BackendStoreDriver string         `json:"backendStoreDriver"`
	PortCount          int32          `json:"portCount"`
	PortArgs           []string       `json:"portArgs"`
	InstanceStatus     InstanceStatus `json:"instanceStatus"`
	Deleted            bool           `json:"deleted"`

	InstanceProccessSpec *InstanceProcessSpec
}

func RPCToInstance added in v1.5.0

func RPCToInstance(obj *rpc.InstanceResponse) *Instance

type InstanceProcessSpec added in v1.5.0

type InstanceProcessSpec struct {
	Binary string   `json:"binary"`
	Args   []string `json:"args"`
}

type InstanceStatus added in v1.5.0

type InstanceStatus struct {
	State      string          `json:"state"`
	ErrorMsg   string          `json:"errorMsg"`
	Conditions map[string]bool `json:"conditions"`
	PortStart  int32           `json:"portStart"`
	PortEnd    int32           `json:"portEnd"`
}

func RPCToInstanceStatus added in v1.5.0

func RPCToInstanceStatus(obj *rpc.InstanceStatus) InstanceStatus

type InstanceStream added in v1.5.0

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

func NewInstanceStream added in v1.5.0

func NewInstanceStream(stream rpc.InstanceService_InstanceWatchClient) *InstanceStream

func (*InstanceStream) Recv added in v1.5.0

func (s *InstanceStream) Recv() (*empty.Empty, error)

type LogStream

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

func (*LogStream) Recv

func (s *LogStream) Recv() (string, error)

type Process

type Process struct {
	Name      string   `json:"name"`
	Binary    string   `json:"binary"`
	Args      []string `json:"args"`
	PortCount int32    `json:"portCount"`
	PortArgs  []string `json:"portArgs"`

	ProcessStatus ProcessStatus `json:"processStatus"`

	Deleted bool `json:"deleted"`
}

func RPCToProcess

func RPCToProcess(obj *rpc.ProcessResponse) *Process

type ProcessStatus

type ProcessStatus struct {
	State      string          `json:"state"`
	ErrorMsg   string          `json:"errorMsg"`
	Conditions map[string]bool `json:"conditions"`
	PortStart  int32           `json:"portStart"`
	PortEnd    int32           `json:"portEnd"`
}

func RPCToProcessStatus

func RPCToProcessStatus(obj *rpc.ProcessStatus) ProcessStatus

type ProcessStream

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

func (*ProcessStream) Recv

func (s *ProcessStream) Recv() (*rpc.ProcessResponse, error)

type ReplicaStorageInstance added in v1.5.0

type ReplicaStorageInstance struct {
	Name       string
	UUID       string
	DiskName   string
	DiskUUID   string
	SpecSize   uint64
	ActualSize uint64
}

ReplicaStorageInstance is utilized to represent a replica directory of a legacy volume and a replica logical volume (lvol) of a SPDK volume.

type ReplicaStream added in v1.5.0

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

func NewReplicaStream added in v1.5.0

func NewReplicaStream(stream spdkrpc.SPDKService_ReplicaWatchClient) *ReplicaStream

func (*ReplicaStream) Recv added in v1.5.0

func (s *ReplicaStream) Recv() (*empty.Empty, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL