server

Documentation

Index

• func NewCircleServer(clusterCache cache.ClusterCache, k8sCache client.Client, ...) pbv1.CircleServiceServer
• func NewResourceServer(k8sCache client.Client, clusterCache cache.ClusterCache, ...) pbv1.ResourceServiceServer
• func NewServer(logger logr.Logger, circleServer pbv1.CircleServiceServer, ...) *server
• type CircleServer
  • func (s CircleServer) Status(ctx context.Context, request *pbv1.GetCircle) (*pbv1.StatusResponse, error)
  • func (s CircleServer) Sync(ctx context.Context, request *pbv1.GetCircle) (*anypb.Any, error)
• type ResourceServer
  • func (r ResourceServer) Events(ctx context.Context, req *pbv1.EventsRequest) (*pbv1.EventsResponse, error)
  • func (r ResourceServer) Get(ctx context.Context, req *pbv1.GetResourceRequest) (*pbv1.Resource, error)
  • func (r ResourceServer) GetResourceHealthAndMessage(resource *cache.Resource) (string, string)
  • func (r ResourceServer) Logs(context.Context, *pbv1.LogsRequest) (*pbv1.LogsResponse, error)
  • func (r ResourceServer) Manifest(ctx context.Context, req *pbv1.GetResourceRequest) (*pbv1.ManifestResponse, error)
  • func (r ResourceServer) Tree(ctx context.Context, request *pbv1.TreeRequest) (*pbv1.TreeResponse, error)

Functions

func NewCircleServer

func NewCircleServer(
	clusterCache cache.ClusterCache,
	k8sCache client.Client,
	circleManager circlemanager.CircleManager,
) pbv1.CircleServiceServer

func NewResourceServer

func NewResourceServer(
	k8sCache client.Client,
	clusterCache cache.ClusterCache,
	kubernetesClient *kubernetes.Clientset,
	dynamicClient dynamic.Interface,
) pbv1.ResourceServiceServer

func NewServer

func NewServer(
	logger logr.Logger,
	circleServer pbv1.CircleServiceServer,
	resourceServer pbv1.ResourceServiceServer,
) *server

Types

type CircleServer

type CircleServer struct {
	// contains filtered or unexported fields
}

func (CircleServer) Status

func (s CircleServer) Status(ctx context.Context, request *pbv1.GetCircle) (*pbv1.StatusResponse, error)

func (CircleServer) Sync

func (s CircleServer) Sync(ctx context.Context, request *pbv1.GetCircle) (*anypb.Any, error)

Tree implements v1.CircleServiceServer

type ResourceServer

type ResourceServer struct {
	// contains filtered or unexported fields
}

func (ResourceServer) Events

func (r ResourceServer) Events(ctx context.Context, req *pbv1.EventsRequest) (*pbv1.EventsResponse, error)

Events implements v1.ResourceServiceServer

func (ResourceServer) Get

func (r ResourceServer) Get(ctx context.Context, req *pbv1.GetResourceRequest) (*pbv1.Resource, error)

Get implements v1.ResourceServiceServer

func (ResourceServer) GetResourceHealthAndMessage

func (r ResourceServer) GetResourceHealthAndMessage(resource *cache.Resource) (string, string)

func (ResourceServer) Logs

func (r ResourceServer) Logs(context.Context, *pbv1.LogsRequest) (*pbv1.LogsResponse, error)

Logs implements v1.ResourceServiceServer

func (ResourceServer) Manifest

func (r ResourceServer) Manifest(ctx context.Context, req *pbv1.GetResourceRequest) (*pbv1.ManifestResponse, error)

func (ResourceServer) Tree

func (r ResourceServer) Tree(ctx context.Context, request *pbv1.TreeRequest) (*pbv1.TreeResponse, error)