principal

Documentation

Index

• Variables
• type Server
  • func (s *Server) Ensure(ctx context.Context, req *principal.EnsureRequest) (*principal.EnsureResponse, error)
  • func (s *Server) List(_ *emptypb.Empty, out principal.Principals_ListServer) error
  • func (s *Server) Load(ctx context.Context, req *principal.LoadRequest) (*principal.Principal, error)
  • func (s *Server) Watch(req *principal.WatchRequest, out principal.Principals_WatchServer) error

Variables

var Set = wire.NewSet(
	wire.Struct(new(Server), "*"),
	wire.Bind(new(principal.PrincipalsServer), new(*Server)),
)

Set is used by wire.

Types

type Server

type Server struct {
	Config                           *config.Config
	DB                               *pgxpool.Pool
	Logger                           *log.Logger
	principal.UnsafePrincipalsServer `wire:"-"`
}

Server implements the principal.PrincipalsServer API.

func (*Server) Ensure

func (s *Server) Ensure(
	ctx context.Context, req *principal.EnsureRequest,
) (*principal.EnsureResponse, error)

Ensure will store the given Principal in the database, updating Principal.Version on successful update.

func (*Server) List

func (s *Server) List(_ *emptypb.Empty, out principal.Principals_ListServer) error

List implements principal.PrincipalsServer.

func (*Server) Load

func (s *Server) Load(ctx context.Context, req *principal.LoadRequest) (*principal.Principal, error)

Load implements principal.PrincipalsServer.

func (*Server) Watch

func (s *Server) Watch(req *principal.WatchRequest, out principal.Principals_WatchServer) error

Watch implements principal.PrincipalsServer.