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
Constants ¶
This section is empty.
Variables ¶
View Source
var Set = wire.NewSet( wire.Struct(new(Server), "*"), wire.Bind(new(principal.PrincipalsServer), new(*Server)), )
Set is used by wire.
Functions ¶
This section is empty.
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) 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.
Source Files
Click to show internal directories.
Click to hide internal directories.