v1beta1

Documentation

Index

• type BackupHandler
  • func NewBackupHandler(l log.Logger, service BackupService) *BackupHandler
  • func (b BackupHandler) CreateBackup(ctx context.Context, req *pb.CreateBackupRequest) (*pb.CreateBackupResponse, error)
  • func (b BackupHandler) GetBackup(ctx context.Context, req *pb.GetBackupRequest) (*pb.GetBackupResponse, error)
  • func (b BackupHandler) ListBackups(ctx context.Context, req *pb.ListBackupsRequest) (*pb.ListBackupsResponse, error)
• type BackupService
• type ResourceHandler
  • func NewResourceHandler(l log.Logger, resourceService ResourceService) *ResourceHandler
  • func (rh ResourceHandler) ApplyResources(ctx context.Context, req *pb.ApplyResourcesRequest) (*pb.ApplyResourcesResponse, error)
  • func (rh ResourceHandler) ChangeResourceNamespace(ctx context.Context, req *pb.ChangeResourceNamespaceRequest) (*pb.ChangeResourceNamespaceResponse, error)
  • func (rh ResourceHandler) CreateResource(ctx context.Context, req *pb.CreateResourceRequest) (*pb.CreateResourceResponse, error)
  • func (rh ResourceHandler) DeleteResource(ctx context.Context, req *pb.DeleteResourceRequest) (*pb.DeleteResourceResponse, error)
  • func (rh ResourceHandler) DeployResourceSpecification(stream pb.ResourceService_DeployResourceSpecificationServer) error
  • func (rh ResourceHandler) ListResourceSpecification(ctx context.Context, req *pb.ListResourceSpecificationRequest) (*pb.ListResourceSpecificationResponse, error)
  • func (rh ResourceHandler) ReadResource(ctx context.Context, req *pb.ReadResourceRequest) (*pb.ReadResourceResponse, error)
  • func (rh ResourceHandler) UpdateResource(ctx context.Context, req *pb.UpdateResourceRequest) (*pb.UpdateResourceResponse, error)
• type ResourceService

Types

type BackupHandler

type BackupHandler struct {
	pb.UnimplementedBackupServiceServer
	// contains filtered or unexported fields
}

func NewBackupHandler

func NewBackupHandler(l log.Logger, service BackupService) *BackupHandler

func (BackupHandler) CreateBackup

func (b BackupHandler) CreateBackup(ctx context.Context, req *pb.CreateBackupRequest) (*pb.CreateBackupResponse, error)

func (BackupHandler) GetBackup

func (b BackupHandler) GetBackup(ctx context.Context, req *pb.GetBackupRequest) (*pb.GetBackupResponse, error)

func (BackupHandler) ListBackups

func (b BackupHandler) ListBackups(ctx context.Context, req *pb.ListBackupsRequest) (*pb.ListBackupsResponse, error)

type BackupService

type BackupService interface {
	Create(context.Context, *resource.Backup) (*resource.BackupResult, error)
	Get(context.Context, resource.BackupID) (*resource.Backup, error)
	List(context.Context, tenant.Tenant, resource.Store) ([]*resource.Backup, error)
}

type ResourceHandler

type ResourceHandler struct {
	pb.UnimplementedResourceServiceServer
	// contains filtered or unexported fields
}

func NewResourceHandler

func NewResourceHandler(l log.Logger, resourceService ResourceService) *ResourceHandler

func (ResourceHandler) ApplyResources

func (rh ResourceHandler) ApplyResources(ctx context.Context, req *pb.ApplyResourcesRequest) (*pb.ApplyResourcesResponse, error)

func (ResourceHandler) ChangeResourceNamespace

func (rh ResourceHandler) ChangeResourceNamespace(ctx context.Context, req *pb.ChangeResourceNamespaceRequest) (*pb.ChangeResourceNamespaceResponse, error)

func (ResourceHandler) CreateResource

func (rh ResourceHandler) CreateResource(ctx context.Context, req *pb.CreateResourceRequest) (*pb.CreateResourceResponse, error)

func (ResourceHandler) DeleteResource

func (rh ResourceHandler) DeleteResource(ctx context.Context, req *pb.DeleteResourceRequest) (*pb.DeleteResourceResponse, error)

func (ResourceHandler) DeployResourceSpecification

func (rh ResourceHandler) DeployResourceSpecification(stream pb.ResourceService_DeployResourceSpecificationServer) error

func (ResourceHandler) ListResourceSpecification

func (rh ResourceHandler) ListResourceSpecification(ctx context.Context, req *pb.ListResourceSpecificationRequest) (*pb.ListResourceSpecificationResponse, error)

func (ResourceHandler) ReadResource

func (rh ResourceHandler) ReadResource(ctx context.Context, req *pb.ReadResourceRequest) (*pb.ReadResourceResponse, error)

func (ResourceHandler) UpdateResource

func (rh ResourceHandler) UpdateResource(ctx context.Context, req *pb.UpdateResourceRequest) (*pb.UpdateResourceResponse, error)

type ResourceService

type ResourceService interface {
	Create(ctx context.Context, res *resource.Resource) error
	Update(ctx context.Context, res *resource.Resource, logWriter writer.LogWriter) error
	Delete(ctx context.Context, req *resource.DeleteRequest) (*resource.DeleteResponse, error)
	ChangeNamespace(ctx context.Context, datastore resource.Store, resourceFullName string, oldTenant, newTenant tenant.Tenant) error
	Get(ctx context.Context, tnnt tenant.Tenant, store resource.Store, resourceName string) (*resource.Resource, error)
	GetAll(ctx context.Context, tnnt tenant.Tenant, store resource.Store) ([]*resource.Resource, error)
	Deploy(ctx context.Context, tnnt tenant.Tenant, store resource.Store, resources []*resource.Resource, logWriter writer.LogWriter) error
	SyncResources(ctx context.Context, tnnt tenant.Tenant, store resource.Store, names []string) (*resource.SyncResponse, error)
}