statd

package
v0.0.0-...-4450389 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 4, 2019 License: MIT Imports: 14 Imported by: 0

Documentation

Overview

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

Index

Constants

View Source
const AAFsoInitRepo = fsoauthz.AAFsoInitRepo
View Source
const AAFsoRefreshRepo = fsoauthz.AAFsoRefreshRepo

Variables

This section is empty.

Functions

This section is empty.

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL