remotesrv

type AccessControl interface {
	// ApiAuthenticate checks the incoming request for authentication credentials and validates them. If the user's
	// identity checks out, the returned context will have the sqlContext within it, which contains the user's ID.
	// If the user is not legitimate, an error is returned.
	ApiAuthenticate(ctx context.Context) (context.Context, error)
	// ApiAuthorize checks that the authenticated user has sufficient privileges to perform the requested action.
	// Currently, our resource policy is binary currently, a user either is a SuperUser (form Commit) or they have a
	// CLONE_ADMIN grant for read operations.
	// More resource aware authorization decisions will be needed in the future, but this is sufficient for now.
	ApiAuthorize(ctx context.Context, superUserReq bool) (bool, error)
}

type DBCache interface {
	Get(ctx context.Context, path, nbfVerStr string) (RemoteSrvStore, error)
}

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

type ReadOnlyChunkStore struct {
	remotesapi.ChunkStoreServiceServer
}

type RemoteChunkStore struct {
	HttpHost string

	remotesapi.UnimplementedChunkStoreServiceServer
	// contains filtered or unexported fields
}

type RemoteSrvStore interface {
	chunks.ChunkStore
	chunks.TableFileStore

	Path() (string, bool)
	GetChunkLocationsWithPaths(hashes hash.HashSet) (map[string]map[hash.Hash]nbs.Range, error)
}

type RequestCredentials struct {
	Username string
	Password string
	Address  string
}

type Sealer interface {
	Seal(*url.URL) (*url.URL, error)
	Unseal(*url.URL) (*url.URL, error)
}

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

type ServerArgs struct {
	Logger   *logrus.Entry
	HttpHost string

	HttpListenAddr string
	GrpcListenAddr string

	FS       filesys.Filesys
	DBCache  DBCache
	ReadOnly bool
	Options  []grpc.ServerOption

	ConcurrencyControl remotesapi.PushConcurrencyControl

	HttpInterceptor func(http.Handler) http.Handler

	// If supplied, the listener(s) returned from Listeners() will be TLS
	// listeners. The scheme used in the URLs returned from the gRPC server
	// will be https.
	TLSConfig *tls.Config
}

type ServerInterceptor struct {
	Lgr              *logrus.Entry
	AccessController AccessControl
}