targetserver

Documentation

Index

• func IsSafeToRetry(err error) bool
• func Reader(r io.Reader) (string, error)
• func ServeRequest(conn net.Conn, clientset clientset.Interface)
• func StartTargetServer(kubeConfig string)
• type CVReplicationDetails
  • func (csr *CVReplicationDetails) BuildConfigData() map[string]string
  • func (csr *CVReplicationDetails) UpdateCVWithReplicationDetails(openebsClient clientset.Interface) error
  • func (csr *CVReplicationDetails) UpdateConfig() error
  • func (csr *CVReplicationDetails) Validate() error

Functions

func IsSafeToRetry

func IsSafeToRetry(err error) bool

IsSafeToRetry will retrun true if error type is EINTR, EAGAIN or EWOULDBLOCK

func Reader

func Reader(r io.Reader) (string, error)

Reader reads the data from wire untill error or endOfData occurs Reader will break only when client is sending \r\n or EOF occured

func ServeRequest

func ServeRequest(conn net.Conn, clientset clientset.Interface)

ServeRequest process the request from the client

func StartTargetServer

func StartTargetServer(kubeConfig string)

StartTargetServer starts the UnixDomainServer

Types

type CVReplicationDetails

type CVReplicationDetails struct {
	VolumeName        string `json:"volumeName"`
	ReplicationFactor int    `json:"replicationFactor"`
	ConsistencyFactor int    `json:"consistencyFactor"`
	ReplicaID         string `json:"replicaId"`
	ReplicaGUID       string `json:"replicaZvolGuid"`
}

CVReplicationDetails enables to update RF,CF and known replicas into etcd

func (*CVReplicationDetails) BuildConfigData

func (csr *CVReplicationDetails) BuildConfigData() map[string]string

BuildConfigData builds data based on the CVReplicationDetails

func (*CVReplicationDetails) UpdateCVWithReplicationDetails

func (csr *CVReplicationDetails) UpdateCVWithReplicationDetails(openebsClient clientset.Interface) error

UpdateCVWithReplicationDetails updates the cstorvolume with known replicas and updated replication details

func (*CVReplicationDetails) UpdateConfig

func (csr *CVReplicationDetails) UpdateConfig() error

UpdateConfig updates target configuration file by building data

func (*CVReplicationDetails) Validate

func (csr *CVReplicationDetails) Validate() error

Validate verifies whether CStorReplication data read on wire is valid or not