statd

Documentation

Overview

Package `statd`: GRPC service `nogfso.Stat`.

Index

• Constants
• type Logger
• type Processor
• type Server
  • func New(lg Logger, authn auth.Authenticator, authz auth.Authorizer, proc Processor, ...) *Server
  • func (srv *Server) Process(ctx context.Context, conn *grpc.ClientConn) error
  • func (srv *Server) RefreshContent(ctx context.Context, req *pb.RefreshContentI) (*pb.RefreshContentO, error)
  • func (srv *Server) ReinitSubdirTracking(ctx context.Context, req *pb.ReinitSubdirTrackingI) (*pb.ReinitSubdirTrackingO, error)
  • func (srv *Server) Sha(ctx context.Context, req *pb.ShaI) (*pb.ShaO, error)
  • func (srv *Server) Stat(ctx context.Context, req *pb.StatI) (*pb.StatO, error)
  • func (srv *Server) StatStatus(i *pb.StatStatusI, ostream pb.Stat_StatStatusServer) error
• type User

Constants

const AAFsoInitRepo = fsoauthz.AAFsoInitRepo

const AAFsoRefreshRepo = fsoauthz.AAFsoRefreshRepo

Types

type Logger

type Logger interface {
	Errorw(msg string, kv ...interface{})
	Infow(msg string, kv ...interface{})
}

type Processor

type Processor interface {
	GlobalRepoPath(repoId uuid.I) (string, bool)
	StatStatus(
		ctx context.Context,
		repoId uuid.I,
		fn shadows.StatStatusFunc,
	) error
	StatRepo(
		ctx context.Context,
		repo uuid.I,
		author User,
		opts shadows.StatOptions,
	) error
	ShaRepo(ctx context.Context, repo uuid.I, author User) error
	RefreshContent(ctx context.Context, repo uuid.I, author User) error
	ReinitSubdirTracking(
		ctx context.Context,
		repo uuid.I,
		author User,
		subdirTracking pb.SubdirTracking,
	) error
}

type Server

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

func New

func New(
	lg Logger,
	authn auth.Authenticator,
	authz auth.Authorizer,
	proc Processor,
	sysRPCCreds credentials.PerRPCCredentials,
) *Server

func (*Server) Process

func (srv *Server) Process(ctx context.Context, conn *grpc.ClientConn) error

`Process()` asynchronously processes stat and sha requests.

func (*Server) RefreshContent

func (srv *Server) RefreshContent(
	ctx context.Context, req *pb.RefreshContentI,
) (*pb.RefreshContentO, error)

func (*Server) ReinitSubdirTracking

func (srv *Server) ReinitSubdirTracking(
	ctx context.Context, req *pb.ReinitSubdirTrackingI,
) (*pb.ReinitSubdirTrackingO, error)

func (*Server) Sha

func (srv *Server) Sha(
	ctx context.Context, req *pb.ShaI,
) (*pb.ShaO, error)

func (*Server) Stat

func (srv *Server) Stat(
	ctx context.Context, req *pb.StatI,
) (*pb.StatO, error)

func (*Server) StatStatus

func (srv *Server) StatStatus(
	i *pb.StatStatusI, ostream pb.Stat_StatStatusServer,
) error

type User

type User struct {
	Name  string
	Email string
}