Documentation ¶
Index ¶
- type APIServer
- func (server APIServer) ApplyAction(ctx context.Context, request *entropyv1beta1.ApplyActionRequest) (*entropyv1beta1.ApplyActionResponse, error)
- func (server APIServer) CreateResource(ctx context.Context, request *entropyv1beta1.CreateResourceRequest) (*entropyv1beta1.CreateResourceResponse, error)
- func (server APIServer) DeleteResource(ctx context.Context, request *entropyv1beta1.DeleteResourceRequest) (*entropyv1beta1.DeleteResourceResponse, error)
- func (server APIServer) GetLog(request *entropyv1beta1.GetLogRequest, ...) error
- func (server APIServer) GetResource(ctx context.Context, request *entropyv1beta1.GetResourceRequest) (*entropyv1beta1.GetResourceResponse, error)
- func (server APIServer) GetResourceRevisions(ctx context.Context, request *entropyv1beta1.GetResourceRevisionsRequest) (*entropyv1beta1.GetResourceRevisionsResponse, error)
- func (server APIServer) ListResources(ctx context.Context, request *entropyv1beta1.ListResourcesRequest) (*entropyv1beta1.ListResourcesResponse, error)
- func (server APIServer) UpdateResource(ctx context.Context, request *entropyv1beta1.UpdateResourceRequest) (*entropyv1beta1.UpdateResourceResponse, error)
- type LogWrapper
- func (lw *LogWrapper) ApplyAction(ctx context.Context, request *entropyv1beta1.ApplyActionRequest) (*entropyv1beta1.ApplyActionResponse, error)
- func (lw *LogWrapper) CreateResource(ctx context.Context, request *entropyv1beta1.CreateResourceRequest) (*entropyv1beta1.CreateResourceResponse, error)
- func (lw *LogWrapper) DeleteResource(ctx context.Context, request *entropyv1beta1.DeleteResourceRequest) (*entropyv1beta1.DeleteResourceResponse, error)
- func (lw *LogWrapper) GetLog(request *entropyv1beta1.GetLogRequest, ...) error
- func (lw *LogWrapper) GetResource(ctx context.Context, request *entropyv1beta1.GetResourceRequest) (*entropyv1beta1.GetResourceResponse, error)
- func (lw *LogWrapper) GetResourceRevisions(ctx context.Context, request *entropyv1beta1.GetResourceRevisionsRequest) (*entropyv1beta1.GetResourceRevisionsResponse, error)
- func (lw *LogWrapper) ListResources(ctx context.Context, request *entropyv1beta1.ListResourcesRequest) (*entropyv1beta1.ListResourcesResponse, error)
- func (lw *LogWrapper) UpdateResource(ctx context.Context, request *entropyv1beta1.UpdateResourceRequest) (*entropyv1beta1.UpdateResourceResponse, error)
- type ResourceService
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type APIServer ¶
type APIServer struct { entropyv1beta1.UnimplementedResourceServiceServer // contains filtered or unexported fields }
func NewAPIServer ¶
func NewAPIServer(resourceService ResourceService) *APIServer
func (APIServer) ApplyAction ¶
func (server APIServer) ApplyAction(ctx context.Context, request *entropyv1beta1.ApplyActionRequest) (*entropyv1beta1.ApplyActionResponse, error)
func (APIServer) CreateResource ¶
func (server APIServer) CreateResource(ctx context.Context, request *entropyv1beta1.CreateResourceRequest) (*entropyv1beta1.CreateResourceResponse, error)
func (APIServer) DeleteResource ¶
func (server APIServer) DeleteResource(ctx context.Context, request *entropyv1beta1.DeleteResourceRequest) (*entropyv1beta1.DeleteResourceResponse, error)
func (APIServer) GetLog ¶
func (server APIServer) GetLog(request *entropyv1beta1.GetLogRequest, stream entropyv1beta1.ResourceService_GetLogServer) error
func (APIServer) GetResource ¶
func (server APIServer) GetResource(ctx context.Context, request *entropyv1beta1.GetResourceRequest) (*entropyv1beta1.GetResourceResponse, error)
func (APIServer) GetResourceRevisions ¶
func (server APIServer) GetResourceRevisions(ctx context.Context, request *entropyv1beta1.GetResourceRevisionsRequest) (*entropyv1beta1.GetResourceRevisionsResponse, error)
func (APIServer) ListResources ¶
func (server APIServer) ListResources(ctx context.Context, request *entropyv1beta1.ListResourcesRequest) (*entropyv1beta1.ListResourcesResponse, error)
func (APIServer) UpdateResource ¶
func (server APIServer) UpdateResource(ctx context.Context, request *entropyv1beta1.UpdateResourceRequest) (*entropyv1beta1.UpdateResourceResponse, error)
type LogWrapper ¶
type LogWrapper struct { entropyv1beta1.ResourceServiceServer Logger *zap.Logger }
func (*LogWrapper) ApplyAction ¶
func (lw *LogWrapper) ApplyAction(ctx context.Context, request *entropyv1beta1.ApplyActionRequest) (*entropyv1beta1.ApplyActionResponse, error)
func (*LogWrapper) CreateResource ¶
func (lw *LogWrapper) CreateResource(ctx context.Context, request *entropyv1beta1.CreateResourceRequest) (*entropyv1beta1.CreateResourceResponse, error)
func (*LogWrapper) DeleteResource ¶
func (lw *LogWrapper) DeleteResource(ctx context.Context, request *entropyv1beta1.DeleteResourceRequest) (*entropyv1beta1.DeleteResourceResponse, error)
func (*LogWrapper) GetLog ¶
func (lw *LogWrapper) GetLog(request *entropyv1beta1.GetLogRequest, server entropyv1beta1.ResourceService_GetLogServer) error
func (*LogWrapper) GetResource ¶
func (lw *LogWrapper) GetResource(ctx context.Context, request *entropyv1beta1.GetResourceRequest) (*entropyv1beta1.GetResourceResponse, error)
func (*LogWrapper) GetResourceRevisions ¶
func (lw *LogWrapper) GetResourceRevisions(ctx context.Context, request *entropyv1beta1.GetResourceRevisionsRequest) (*entropyv1beta1.GetResourceRevisionsResponse, error)
func (*LogWrapper) ListResources ¶
func (lw *LogWrapper) ListResources(ctx context.Context, request *entropyv1beta1.ListResourcesRequest) (*entropyv1beta1.ListResourcesResponse, error)
func (*LogWrapper) UpdateResource ¶
func (lw *LogWrapper) UpdateResource(ctx context.Context, request *entropyv1beta1.UpdateResourceRequest) (*entropyv1beta1.UpdateResourceResponse, error)
type ResourceService ¶
type ResourceService interface { GetResource(ctx context.Context, urn string) (*resource.Resource, error) ListResources(ctx context.Context, filter resource.Filter) ([]resource.Resource, error) CreateResource(ctx context.Context, res resource.Resource) (*resource.Resource, error) UpdateResource(ctx context.Context, urn string, req resource.UpdateRequest) (*resource.Resource, error) DeleteResource(ctx context.Context, urn string) error ApplyAction(ctx context.Context, urn string, action module.ActionRequest) (*resource.Resource, error) GetLog(ctx context.Context, urn string, filter map[string]string) (<-chan module.LogChunk, error) GetRevisions(ctx context.Context, selector resource.RevisionsSelector) ([]resource.Revision, error) }
Click to show internal directories.
Click to hide internal directories.