pb

Documentation

Index

• Constants
• func GrpcDial(ctx context.Context, address string, opts ...grpc.DialOption) (*grpc.ClientConn, error)
• func MaybeLoadVolumeInfo(fileName string) (*volume_server_pb.VolumeInfo, bool, error)
• func NewGrpcServer(opts ...grpc.ServerOption) *grpc.Server
• func ParseFilerGrpcAddress(filer string) (filerGrpcAddress string, err error)
• func ParseServerToGrpcAddress(server string) (serverGrpcAddress string, err error)
• func SaveVolumeInfo(fileName string, volumeInfo *volume_server_pb.VolumeInfo) error
• func ServerToGrpcAddress(server string) (serverGrpcAddress string)
• func WithBrokerGrpcClient(brokerGrpcAddress string, grpcDialOption grpc.DialOption, ...) error
• func WithCachedGrpcClient(fn func(*grpc.ClientConn) error, address string, opts ...grpc.DialOption) error
• func WithFilerClient(filer string, grpcDialOption grpc.DialOption, ...) error
• func WithGrpcFilerClient(filerGrpcAddress string, grpcDialOption grpc.DialOption, ...) error
• func WithMasterClient(master string, grpcDialOption grpc.DialOption, ...) error

Constants

const (
	AdminShellClient = "adminShell"
)

const (
	Max_Message_Size = 1 << 30 // 1 GB
)

Functions

func GrpcDial

func GrpcDial(ctx context.Context, address string, opts ...grpc.DialOption) (*grpc.ClientConn, error)

func MaybeLoadVolumeInfo

func MaybeLoadVolumeInfo(fileName string) (*volume_server_pb.VolumeInfo, bool, error)

MaybeLoadVolumeInfo load the file data as *volume_server_pb.VolumeInfo, the returned volumeInfo will not be nil

func NewGrpcServer

func NewGrpcServer(opts ...grpc.ServerOption) *grpc.Server

func ParseFilerGrpcAddress

func ParseFilerGrpcAddress(filer string) (filerGrpcAddress string, err error)

func ParseServerToGrpcAddress

func ParseServerToGrpcAddress(server string) (serverGrpcAddress string, err error)

func SaveVolumeInfo

func SaveVolumeInfo(fileName string, volumeInfo *volume_server_pb.VolumeInfo) error

func ServerToGrpcAddress

func ServerToGrpcAddress(server string) (serverGrpcAddress string)

func WithBrokerGrpcClient

func WithBrokerGrpcClient(brokerGrpcAddress string, grpcDialOption grpc.DialOption, fn func(client messaging_pb.SeaweedMessagingClient) error) error

func WithCachedGrpcClient

func WithCachedGrpcClient(fn func(*grpc.ClientConn) error, address string, opts ...grpc.DialOption) error

func WithFilerClient

func WithFilerClient(filer string, grpcDialOption grpc.DialOption, fn func(client filer_pb.SeaweedFilerClient) error) error

func WithGrpcFilerClient

func WithGrpcFilerClient(filerGrpcAddress string, grpcDialOption grpc.DialOption, fn func(client filer_pb.SeaweedFilerClient) error) error

func WithMasterClient

func WithMasterClient(master string, grpcDialOption grpc.DialOption, fn func(client master_pb.SeaweedClient) error) error