Documentation
¶
Index ¶
- func Asset(name string) ([]byte, error)
- func AssetDir(name string) ([]string, error)
- func AssetInfo(name string) (os.FileInfo, error)
- func AssetNames() []string
- func ClaimsFromContext(ctx context.Context) (*jws.ClaimSet, bool)
- func HandleSwagger(mux *http.ServeMux)
- func MakeAuthStreamingInterceptor(kf keysFunc) ...
- func MakeAuthUnaryInterceptor(kf keysFunc) ...
- func MustAsset(name string) []byte
- func Register(ctx context.Context, srv *http.Server, grpcServer *grpc.Server, ...) error
- func RegisterStats()
- func RestoreAsset(dir, name string) error
- func RestoreAssets(dir, name string) error
- func WithCheckClaims(check bool) serverOpt
- func WithGrafanaBasicAuth(user, pass string) serverOpt
- func WithIndex(index *indexer.Indexer) serverOpt
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Asset ¶
Asset loads and returns the asset for the given name. It returns an error if the asset could not be found or could not be loaded.
func AssetDir ¶
AssetDir returns the file names below a certain directory embedded in the file by go-bindata. For example if you run go-bindata on data/... and data contains the following hierarchy:
data/
foo.txt
img/
a.png
b.png
then AssetDir("data") would return []string{"foo.txt", "img"} AssetDir("data/img") would return []string{"a.png", "b.png"} AssetDir("foo.txt") and AssetDir("notexist") would return an error AssetDir("") will return []string{"data"}.
func AssetInfo ¶
AssetInfo loads and returns the asset info for the given name. It returns an error if the asset could not be found or could not be loaded.
func ClaimsFromContext ¶
ClaimsFromContext retrieves the set of claims stored in a request context
func HandleSwagger ¶
HandleSwagger adds the swagger-ui to the provided mux
func MakeAuthStreamingInterceptor ¶
func MakeAuthStreamingInterceptor(kf keysFunc) func(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error
MakeAuthStreamingInterceptor is gRPC stream interceptor that checks for the required claims in JWT in the authorization header.
func MakeAuthUnaryInterceptor ¶
func MakeAuthUnaryInterceptor(kf keysFunc) func(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)
MakeAuthUnaryInterceptor is gRPC unary interceptor that checks for the required claims in JWT in the authorization header.
func MustAsset ¶
MustAsset is like Asset but panics when Asset would return an error. It simplifies safe initialization of global variables.
func Register ¶
func Register(ctx context.Context, srv *http.Server, grpcServer *grpc.Server, dopts []grpc.DialOption, opts ...serverOpt) error
Register sets up the log server on the provided http and grpc servers. THe dial options will be used for all outbound gRPC reuqests.
func RegisterStats ¶
func RegisterStats()
RegisterStats explicitly register the prometheus metrics, this prevents them showing up in the client
func RestoreAsset ¶
RestoreAsset restores an asset under the given directory
func RestoreAssets ¶
RestoreAssets restores an asset under the given directory recursively
func WithCheckClaims ¶
func WithCheckClaims(check bool) serverOpt
func WithGrafanaBasicAuth ¶
func WithGrafanaBasicAuth(user, pass string) serverOpt
Types ¶
This section is empty.
Source Files