server

Documentation

Index

• type AdminServer
  • func NewAdmin(store *store.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

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 *store.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.