primary

Documentation

Index

• type PrimaryHandler
  • func NewPrimaryHandler(logger *log.Logger) *PrimaryHandler
  • func (handler *PrimaryHandler) Copy(ctx context.Context, req *fs3.CopyRequest) (reply *fs3.CopyReply, err error)
  • func (handler *PrimaryHandler) Describe(ctx context.Context, req *fs3.DescribeRequest) (*fs3.DescribeReply, error)
  • func (handler *PrimaryHandler) Get(ctx context.Context, req *fs3.GetRequest) (*fs3.GetReply, error)
  • func (handler *PrimaryHandler) Remove(ctx context.Context, req *fs3.RemoveRequest) (reply *fs3.RemoveReply, err error)
  • func (handler *PrimaryHandler) VerifyPBClient()

Types

type PrimaryHandler

type PrimaryHandler struct {
	Fs3processor *fs3processor.Fs3RequestProcessor
	PBClient     primarybackup.BackupClient
	Logger       *log.Logger
	fs3.UnimplementedFs3Server
}

func NewPrimaryHandler

func NewPrimaryHandler(logger *log.Logger) *PrimaryHandler

func (*PrimaryHandler) Copy

func (handler *PrimaryHandler) Copy(
	ctx context.Context,
	req *fs3.CopyRequest,
) (reply *fs3.CopyReply, err error)

func (*PrimaryHandler) Describe

func (handler *PrimaryHandler) Describe(
	ctx context.Context,
	req *fs3.DescribeRequest,
) (*fs3.DescribeReply, error)

func (*PrimaryHandler) Get

func (handler *PrimaryHandler) Get(
	ctx context.Context,
	req *fs3.GetRequest,
) (*fs3.GetReply, error)

no need to forward, optimization

func (*PrimaryHandler) Remove

func (handler *PrimaryHandler) Remove(
	ctx context.Context,
	req *fs3.RemoveRequest,
) (reply *fs3.RemoveReply, err error)

func (*PrimaryHandler) VerifyPBClient

func (handler *PrimaryHandler) VerifyPBClient()

before using PBClient, functions should call VerifyPBClient which lazily creates connection to backup