wdclient

Documentation

Index

• type Location
• type MasterClient
  • func NewMasterClient(ctx context.Context, grpcDialOption grpc.DialOption, clientName string, ...) *MasterClient
  • func (vc *MasterClient) GetLocations(vid uint32) (locations []Location)
  • func (mc *MasterClient) GetMaster() string
  • func (vc *MasterClient) GetRandomLocation(vid uint32) (serverUrl string, err error)
  • func (vc *MasterClient) GetVidLocations(vid string) (locations []Location)
  • func (mc *MasterClient) KeepConnectedToMaster()
  • func (vc *MasterClient) LookupFileId(fileId string) (fullUrl string, err error)
  • func (vc *MasterClient) LookupVolumeServer(fileId string) (volumeServer string, err error)
  • func (vc *MasterClient) LookupVolumeServerUrl(vid string) (serverUrl string, err error)
  • func (mc *MasterClient) WaitUntilConnected()
  • func (mc *MasterClient) WithClient(ctx context.Context, 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(ctx context.Context, grpcDialOption grpc.DialOption, clientName string, masters []string) *MasterClient

func (*MasterClient) GetLocations

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

func (*MasterClient) GetMaster

func (mc *MasterClient) GetMaster() string

func (*MasterClient) GetRandomLocation

func (vc *MasterClient) GetRandomLocation(vid uint32) (serverUrl string, err error)

func (*MasterClient) GetVidLocations

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

func (*MasterClient) KeepConnectedToMaster

func (mc *MasterClient) KeepConnectedToMaster()

func (*MasterClient) LookupFileId

func (vc *MasterClient) LookupFileId(fileId string) (fullUrl string, err error)

func (*MasterClient) LookupVolumeServer

func (vc *MasterClient) LookupVolumeServer(fileId string) (volumeServer string, err error)

func (*MasterClient) LookupVolumeServerUrl

func (vc *MasterClient) LookupVolumeServerUrl(vid string) (serverUrl string, err error)

func (*MasterClient) WaitUntilConnected

func (mc *MasterClient) WaitUntilConnected()

func (*MasterClient) WithClient

func (mc *MasterClient) WithClient(ctx context.Context, fn func(client master_pb.SeaweedClient) error) error