server

Documentation

Index

• type HealthServer
  • func NewHealthServer() *HealthServer
  • func (s *HealthServer) Check(ctx context.Context, req *health.HealthCheckRequest) (*health.HealthCheckResponse, error)
• type RegistryServer
  • func NewRegistryServer(store registry.GRPCQuery) *RegistryServer
  • func (s *RegistryServer) GetBundle(ctx context.Context, req *api.GetBundleRequest) (*api.Bundle, error)
  • func (s *RegistryServer) GetBundleForChannel(ctx context.Context, req *api.GetBundleInChannelRequest) (*api.Bundle, error)
  • func (s *RegistryServer) GetBundleThatReplaces(ctx context.Context, req *api.GetReplacementRequest) (*api.Bundle, error)
  • func (s *RegistryServer) GetChannelEntriesThatProvide(req *api.GetAllProvidersRequest, ...) error
  • func (s *RegistryServer) GetChannelEntriesThatReplace(req *api.GetAllReplacementsRequest, ...) error
  • func (s *RegistryServer) GetDefaultBundleThatProvides(ctx context.Context, req *api.GetDefaultProviderRequest) (*api.Bundle, error)
  • func (s *RegistryServer) GetLatestChannelEntriesThatProvide(req *api.GetLatestProvidersRequest, ...) error
  • func (s *RegistryServer) GetPackage(ctx context.Context, req *api.GetPackageRequest) (*api.Package, error)
  • func (s *RegistryServer) ListBundles(req *api.ListBundlesRequest, stream api.Registry_ListBundlesServer) error
  • func (s *RegistryServer) ListPackages(req *api.ListPackageRequest, stream api.Registry_ListPackagesServer) error

Types

type HealthServer

type HealthServer struct {
	health.UnimplementedHealthServer
}

func NewHealthServer

func NewHealthServer() *HealthServer

func (*HealthServer) Check

func (s *HealthServer) Check(ctx context.Context, req *health.HealthCheckRequest) (*health.HealthCheckResponse, error)

type RegistryServer

type RegistryServer struct {
	api.UnimplementedRegistryServer
	// contains filtered or unexported fields
}

func NewRegistryServer

func NewRegistryServer(store registry.GRPCQuery) *RegistryServer

func (*RegistryServer) GetBundle

func (s *RegistryServer) GetBundle(ctx context.Context, req *api.GetBundleRequest) (*api.Bundle, error)

func (*RegistryServer) GetBundleForChannel

func (s *RegistryServer) GetBundleForChannel(ctx context.Context, req *api.GetBundleInChannelRequest) (*api.Bundle, error)

func (*RegistryServer) GetBundleThatReplaces

func (s *RegistryServer) GetBundleThatReplaces(ctx context.Context, req *api.GetReplacementRequest) (*api.Bundle, error)

func (*RegistryServer) GetChannelEntriesThatProvide

func (s *RegistryServer) GetChannelEntriesThatProvide(req *api.GetAllProvidersRequest, stream api.Registry_GetChannelEntriesThatProvideServer) error

func (*RegistryServer) GetChannelEntriesThatReplace

func (s *RegistryServer) GetChannelEntriesThatReplace(req *api.GetAllReplacementsRequest, stream api.Registry_GetChannelEntriesThatReplaceServer) error

func (*RegistryServer) GetDefaultBundleThatProvides

func (s *RegistryServer) GetDefaultBundleThatProvides(ctx context.Context, req *api.GetDefaultProviderRequest) (*api.Bundle, error)

func (*RegistryServer) GetLatestChannelEntriesThatProvide

func (s *RegistryServer) GetLatestChannelEntriesThatProvide(req *api.GetLatestProvidersRequest, stream api.Registry_GetLatestChannelEntriesThatProvideServer) error

func (*RegistryServer) GetPackage

func (s *RegistryServer) GetPackage(ctx context.Context, req *api.GetPackageRequest) (*api.Package, error)

func (*RegistryServer) ListBundles

func (s *RegistryServer) ListBundles(req *api.ListBundlesRequest, stream api.Registry_ListBundlesServer) error

func (*RegistryServer) ListPackages

func (s *RegistryServer) ListPackages(req *api.ListPackageRequest, stream api.Registry_ListPackagesServer) error