Versions in this module Expand all Collapse all v0 v0.4.0 Nov 7, 2026 Changes in this version + const DefaultRetryAfter + const MaxChunk + func AdmissionInterceptor() grpc.UnaryServerInterceptor + func AdmissionStreamInterceptor() grpc.StreamServerInterceptor + func CallerFrom(ctx context.Context) (tlsconf.Caller, bool) + func CallerInterceptor() grpc.UnaryServerInterceptor + func CallerStreamInterceptor() grpc.StreamServerInterceptor + func ConnContext(ctx context.Context, _ net.Conn) context.Context + func FenceFromProto(f *grantv1.Fence) core.Fence + func HealthFunc(epoch func() uint64, health *core.SourceHealth, tier core.Tier, ...) func() map[string]any + func IsMiss(err error) bool + func IsNoWorkspace(err error) bool + func MissFromError(err error) (*grantv1.Miss, bool) + func NewGRPCServer(s *Server, opts ...grpc.ServerOption) *grpc.Server + func RejectUnknown(m protoreflect.Message) error + func ServerCreds(cfg *tls.Config) credentials.TransportCredentials + func StatusToProto(st core.Status) *grantv1.Status + func WithCaller(ctx context.Context, c tlsconf.Caller) context.Context + func WithDraining(health func() map[string]any, draining func() bool) func() map[string]any + func WriteHealth(w http.ResponseWriter, body map[string]any) + func WrongHomeFromError(err error) (*grantv1.WrongHome, bool) + type Gateway struct + Health func() map[string]any + Server *Server + func (g *Gateway) Handler() http.Handler + type Server struct + Core *core.Core + Issuer string + RetryAfter time.Duration + func (s *Server) Clone(ctx context.Context, req *grantv1.CloneRequest) (*grantv1.CloneResponse, error) + func (s *Server) Discard(ctx context.Context, req *grantv1.DiscardRequest) (*emptypb.Empty, error) + func (s *Server) Download(req *grantv1.DownloadRequest, stream grantv1.Fibers_DownloadServer) error + func (s *Server) ListFiles(ctx context.Context, req *grantv1.ListFilesRequest) (*grantv1.ListFilesResponse, error) + func (s *Server) Park(ctx context.Context, req *grantv1.ParkRequest) (*emptypb.Empty, error) + func (s *Server) Release(ctx context.Context, req *grantv1.ReleaseRequest) (*emptypb.Empty, error) + func (s *Server) ToError(code core.StatusCode, err error) error + func (s *Server) Upload(stream grantv1.Fibers_UploadServer) error + func (s *Server) Watch(_ *emptypb.Empty, stream grantv1.Fibers_WatchServer) error v0.4.0-rc.1 Nov 6, 2026
Go to main page