sched

Documentation

Index

• type Filter
• type FilterInterceptor
  • func (fi *FilterInterceptor) SchedUnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

Types

type Filter

type Filter interface {
	PreVolumeCreate(req *csi.CreateVolumeRequest) (*csi.CreateVolumeRequest, error)
}

type FilterInterceptor

type FilterInterceptor struct {
	Filter
}

FilterInterceptor is a wrapper for the filter to be used an interceptor

func (*FilterInterceptor) SchedUnaryInterceptor

func (fi *FilterInterceptor) SchedUnaryInterceptor(
	ctx context.Context,
	req interface{},
	info *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler,
) (interface{}, error)

SchedUnaryInterceptor calls the filter function based on the req