wdclient

Documentation

Index

• type Location
• type MasterClient
  • func NewMasterClient(grpcDialOption grpc.DialOption, clientType string, clientHost string, ...) *MasterClient
  • func (mc *MasterClient) FindLeaderFromOtherPeers(myMasterAddress string) (leader string)
  • func (vc *MasterClient) GetLocations(vid uint32) (locations []Location, found bool)
  • func (mc *MasterClient) GetMaster() string
  • func (vc *MasterClient) GetVidLocations(vid string) (locations []Location, err error)
  • func (mc *MasterClient) KeepConnectedToMaster()
  • func (vc *MasterClient) LookupFileId(fileId string) (fullUrls []string, err error)
  • func (vc *MasterClient) LookupVolumeServerUrl(vid string) (serverUrls []string, err error)
  • func (mc *MasterClient) WaitUntilConnected()
  • func (mc *MasterClient) WithClient(fn func(client master_pb.SeaweedClient) error) error

Types

type Location

type Location struct {
	Url       string `json:"url,omitempty"`
	PublicUrl string `json:"publicUrl,omitempty"`
}

type MasterClient

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

func NewMasterClient

func NewMasterClient(grpcDialOption grpc.DialOption, clientType string, clientHost string, clientGrpcPort uint32, masters []string) *MasterClient

func (*MasterClient) FindLeaderFromOtherPeers

func (mc *MasterClient) FindLeaderFromOtherPeers(myMasterAddress string) (leader string)

func (*MasterClient) GetLocations

func (vc *MasterClient) GetLocations(vid uint32) (locations []Location, found bool)

func (*MasterClient) GetMaster

func (mc *MasterClient) GetMaster() string

func (*MasterClient) GetVidLocations

func (vc *MasterClient) GetVidLocations(vid string) (locations []Location, err error)

func (*MasterClient) KeepConnectedToMaster

func (mc *MasterClient) KeepConnectedToMaster()

func (*MasterClient) LookupFileId

func (vc *MasterClient) LookupFileId(fileId string) (fullUrls []string, err error)

func (*MasterClient) LookupVolumeServerUrl

func (vc *MasterClient) LookupVolumeServerUrl(vid string) (serverUrls []string, err error)

func (*MasterClient) WaitUntilConnected

func (mc *MasterClient) WaitUntilConnected()

func (*MasterClient) WithClient

func (mc *MasterClient) WithClient(fn func(client master_pb.SeaweedClient) error) error