rpc

Documentation

Index

• type ShareManagerHealthCheckServer
  • func NewShareManagerHealthCheckServer(srv *ShareManagerServer) *ShareManagerHealthCheckServer
  • func (s *ShareManagerHealthCheckServer) Check(context.Context, *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)
  • func (s *ShareManagerHealthCheckServer) Watch(req *healthpb.HealthCheckRequest, ws healthpb.Health_WatchServer) error
• type ShareManagerServer
  • func NewShareManagerServer(manager *server.ShareManager) *ShareManagerServer
  • func (s *ShareManagerServer) FilesystemResize(ctx context.Context, req *emptypb.Empty) (resp *emptypb.Empty, err error)
  • func (s *ShareManagerServer) FilesystemTrim(ctx context.Context, req *smrpc.FilesystemTrimRequest) (resp *emptypb.Empty, err error)
  • func (s *ShareManagerServer) Mount(ctx context.Context, req *emptypb.Empty) (resp *emptypb.Empty, err error)
  • func (s *ShareManagerServer) Unmount(ctx context.Context, req *emptypb.Empty) (resp *emptypb.Empty, err error)

Types

type ShareManagerHealthCheckServer

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

func NewShareManagerHealthCheckServer

func NewShareManagerHealthCheckServer(srv *ShareManagerServer) *ShareManagerHealthCheckServer

func (*ShareManagerHealthCheckServer) Check

func (s *ShareManagerHealthCheckServer) Check(context.Context, *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)

func (*ShareManagerHealthCheckServer) Watch

func (s *ShareManagerHealthCheckServer) Watch(req *healthpb.HealthCheckRequest, ws healthpb.Health_WatchServer) error

type ShareManagerServer

type ShareManagerServer struct {
	smrpc.UnimplementedShareManagerServiceServer
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewShareManagerServer

func NewShareManagerServer(manager *server.ShareManager) *ShareManagerServer

func (*ShareManagerServer) FilesystemResize

func (s *ShareManagerServer) FilesystemResize(ctx context.Context, req *emptypb.Empty) (resp *emptypb.Empty, err error)

func (*ShareManagerServer) FilesystemTrim

func (s *ShareManagerServer) FilesystemTrim(ctx context.Context, req *smrpc.FilesystemTrimRequest) (resp *emptypb.Empty, err error)

func (*ShareManagerServer) Mount

func (s *ShareManagerServer) Mount(ctx context.Context, req *emptypb.Empty) (resp *emptypb.Empty, err error)

func (*ShareManagerServer) Unmount

func (s *ShareManagerServer) Unmount(ctx context.Context, req *emptypb.Empty) (resp *emptypb.Empty, err error)