server

Documentation

Index

• type AdminServer
  • func NewAdmin(store *pkgstore.Store, logger logr.Logger) *AdminServer
  • func (s *AdminServer) GetAggregatedSummary(ctx context.Context, req *v1.GetAggregatedSummaryRequest) (*v1.AggregatedSummary, error)
  • func (s *AdminServer) Run(ctx context.Context, port int) error
• type InternalServer
  • func NewInternal(store *store.Store, logger logr.Logger) *InternalServer
  • func (s *InternalServer) CreateUsage(ctx context.Context, req *v1.CreateUsageRequest) (*v1.Usage, error)
  • func (s *InternalServer) Run(ctx context.Context, port int) error
• type Server
  • func New(store *pkgstore.Store, cache cacheGetter, logger logr.Logger) *Server
  • func (s *Server) ListModelUsageSummaries(ctx context.Context, req *v1.ListModelUsageSummariesRequest) (*v1.ListModelUsageSummariesResponse, error)
  • func (s *Server) ListUsageData(ctx context.Context, req *v1.ListUsageDataRequest) (*v1.ListUsageDataResponse, error)
  • func (s *Server) Run(ctx context.Context, port int, authConfig config.AuthConfig) error
  • func (s *Server) Stop()

Types

type AdminServer

type AdminServer struct {
	v1.UnimplementedAPIUsageServiceServer
	// contains filtered or unexported fields
}

AdminServer is the server for the api-usage service.

func NewAdmin

func NewAdmin(store *pkgstore.Store, logger logr.Logger) *AdminServer

NewAdmin creates a new admin server.

func (*AdminServer) GetAggregatedSummary

func (s *AdminServer) GetAggregatedSummary(ctx context.Context, req *v1.GetAggregatedSummaryRequest) (*v1.AggregatedSummary, error)

GetAggregatedSummary aggregates the API usage in the specified time range.

func (*AdminServer) Run

func (s *AdminServer) Run(ctx context.Context, port int) error

Run starts the admin server.

type InternalServer

type InternalServer struct {
	v1.UnimplementedCollectionInternalServiceServer
	// contains filtered or unexported fields
}

InternalServer is the server for the collection service.

func NewInternal

func NewInternal(store *store.Store, logger logr.Logger) *InternalServer

NewInternal creates a new internal server.

func (*InternalServer) CreateUsage

func (s *InternalServer) CreateUsage(ctx context.Context, req *v1.CreateUsageRequest) (*v1.Usage, error)

CreateUsage creates usage.

func (*InternalServer) Run

func (s *InternalServer) Run(ctx context.Context, port int) error

Run starts the internal gRPC server.

type Server

type Server struct {
	v1.UnimplementedAPIUsageServiceServer
	// contains filtered or unexported fields
}

Server is the server for the api-usage service.

func New

func New(store *pkgstore.Store, cache cacheGetter, logger logr.Logger) *Server

New creates a new server.

func (*Server) ListModelUsageSummaries

func (s *Server) ListModelUsageSummaries(ctx context.Context, req *v1.ListModelUsageSummariesRequest) (*v1.ListModelUsageSummariesResponse, error)

ListModelUsageSummaries lists model usage summaries.

func (*Server) ListUsageData

func (s *Server) ListUsageData(ctx context.Context, req *v1.ListUsageDataRequest) (*v1.ListUsageDataResponse, error)

ListUsageData list the usages by groups.

func (*Server) Run

func (s *Server) Run(ctx context.Context, port int, authConfig config.AuthConfig) error

Run starts the server.

func (*Server) Stop

func (s *Server) Stop()

Stop stops the gRPC server.