api

Documentation

Index

• func RPCToInstanceList(obj *rpc.InstanceListResponse) map[string]*Instance
• func RPCToProcessList(obj *rpc.ProcessListResponse) map[string]*Process
• type DiskInfo
• type EngineStream
  • func NewEngineStream(stream spdkrpc.SPDKService_EngineWatchClient) *EngineStream
  • func (s *EngineStream) Recv() (*emptypb.Empty, error)
• type Instance
  • func RPCToInstance(obj *rpc.InstanceResponse) *Instance
• type InstanceProcessSpec
• type InstanceStatus
  • func RPCToInstanceStatus(obj *rpc.InstanceStatus) InstanceStatus
• type InstanceStream
  • func NewInstanceStream(stream rpc.InstanceService_InstanceWatchClient) *InstanceStream
  • func (s *InstanceStream) Recv() (*emptypb.Empty, error)
• type LogStream
  • func NewLogStream(stream rpc.ProcessManagerService_ProcessLogClient) *LogStream
  • func (s *LogStream) Recv() (string, error)
• type Process
  • func RPCToProcess(obj *rpc.ProcessResponse) *Process
• type ProcessStatus
  • func RPCToProcessStatus(obj *rpc.ProcessStatus) ProcessStatus
• type ProcessStream
  • func NewProcessStream(stream rpc.ProcessManagerService_ProcessWatchClient) *ProcessStream
  • func (s *ProcessStream) Recv() (*rpc.ProcessResponse, error)
• type ReplicaStorageInstance
• type ReplicaStream
  • func NewReplicaStream(stream spdkrpc.SPDKService_ReplicaWatchClient) *ReplicaStream
  • func (s *ReplicaStream) Recv() (*emptypb.Empty, error)

Functions

func RPCToInstanceList

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

func RPCToProcessList

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

Types

type DiskInfo

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

type EngineStream

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

func NewEngineStream

func NewEngineStream(stream spdkrpc.SPDKService_EngineWatchClient) *EngineStream

func (*EngineStream) Recv

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

type Instance

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

	InstanceProccessSpec *InstanceProcessSpec

	// Deprecated: replaced by DataEngine.
	BackendStoreDriver string `json:"backendStoreDriver"`
}

func RPCToInstance

func RPCToInstance(obj *rpc.InstanceResponse) *Instance

type InstanceProcessSpec

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

type InstanceStatus

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"`
	TargetPortStart int32           `json:"targetPortStart"`
	TargetPortEnd   int32           `json:"targetPortEnd"`
}

func RPCToInstanceStatus

func RPCToInstanceStatus(obj *rpc.InstanceStatus) InstanceStatus

type InstanceStream

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

func NewInstanceStream

func NewInstanceStream(stream rpc.InstanceService_InstanceWatchClient) *InstanceStream

func (*InstanceStream) Recv

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

type LogStream

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

func NewLogStream

func NewLogStream(stream rpc.ProcessManagerService_ProcessLogClient) *LogStream

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 NewProcessStream

func NewProcessStream(stream rpc.ProcessManagerService_ProcessWatchClient) *ProcessStream

func (*ProcessStream) Recv

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

type ReplicaStorageInstance

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

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

func NewReplicaStream

func NewReplicaStream(stream spdkrpc.SPDKService_ReplicaWatchClient) *ReplicaStream

func (*ReplicaStream) Recv

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