service

Documentation

Index

• Constants
• Variables
• type DataMigrationService
  • func NewDataMigrationService(m *migrate.Migrate) *DataMigrationService
  • func (dms *DataMigrationService) RegisterWithServer(srv *grpc.Server)
  • func (dms *DataMigrationService) Upgrade(ctx context.Context, req *pb.DataMigrationUpgradeRequest) (*pb.DataMigrationUpgradeResponse, error)
  • func (dms *DataMigrationService) Version(ctx context.Context, req *pb.DataMigrationVersionRequest) (*pb.DataMigrationVersionResponse, error)
• type DentryService
  • func NewDentryService(store store.Store, k8s *kubernetes.Clientset) *DentryService
  • func (n *DentryService) DelegationTables(ctx context.Context, req *pb.DelegationTablesRequest) (*pb.DelegationTablesResponse, error)
  • func (s *DentryService) DeleteDentryById(ctx context.Context, req *pb.DeleteDentryByIdRequest) (*pb.DeleteDentryByIdResponse, error)
  • func (s *DentryService) DeleteDentryByPrefix(ctx context.Context, req *pb.DeleteDentryByPrefixRequest) (*pb.DeleteDentryByPrefixResponse, error)
  • func (n *DentryService) Dentries(ctx context.Context, req *pb.DentriesRequest) (*pb.DentriesResponse, error)
  • func (s *DentryService) PutDentry(ctx context.Context, req *pb.PutDentryRequest) (*pb.PutDentryResponse, error)
  • func (s *DentryService) PutService(ctx context.Context, req *pb.PutServiceRequest) (*pb.PutServiceResponse, error)
  • func (ds *DentryService) RegisterWithServer(srv *grpc.Server)
  • func (s *DentryService) RouteToVersion(ctx context.Context, req *pb.RouteToVersionRequest) (*pb.RouteToVersionResponse, error)
• type ServiceSelectorDentryPutter

Constants

const (
	DtabAnnotation           = "compass.thisissoon.com/dtab"
	DentryPrefixAnnotation   = "compass.thisissoon.com/dentry-prefix"
	DentryPriorityAnnotation = "compass.thisissoon.com/dentry-priority"
	PortNameAnnotation       = "compass.thisissoon.com/port-name"
)

Variables

var (
	ErrServiceNotFound                 = errors.New("kubernetets service not found")
	ErrMultipleServicesFound           = errors.New("Too many kubernetets services found")
	ErrMissingDtabAnnotation           = fmt.Errorf("service missing annotation: %s", DtabAnnotation)
	ErrMissingDentryPriorityAnnotation = fmt.Errorf("service missing annotation: %s", DentryPriorityAnnotation)
	ErrMissingPortNameAnnotation       = fmt.Errorf("service missing annotation: %s", PortNameAnnotation)
)

Types

type DataMigrationService

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

func NewDataMigrationService

func NewDataMigrationService(m *migrate.Migrate) *DataMigrationService

func (*DataMigrationService) RegisterWithServer

func (dms *DataMigrationService) RegisterWithServer(srv *grpc.Server)

func (*DataMigrationService) Upgrade

func (dms *DataMigrationService) Upgrade(ctx context.Context, req *pb.DataMigrationUpgradeRequest) (*pb.DataMigrationUpgradeResponse, error)

func (*DataMigrationService) Version

func (dms *DataMigrationService) Version(ctx context.Context, req *pb.DataMigrationVersionRequest) (*pb.DataMigrationVersionResponse, error)

type DentryService

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

Manager implements the pb.NeedleServiceServer interface and thus handles gRPC requests

func NewDentryService

func NewDentryService(store store.Store, k8s *kubernetes.Clientset) *DentryService

NewDentryService returns a new DentryService

func (*DentryService) DelegationTables

func (n *DentryService) DelegationTables(ctx context.Context, req *pb.DelegationTablesRequest) (*pb.DelegationTablesResponse, error)

DelegationTables returns a list of delgation tables managed by needle

func (*DentryService) DeleteDentryById

func (s *DentryService) DeleteDentryById(ctx context.Context, req *pb.DeleteDentryByIdRequest) (*pb.DeleteDentryByIdResponse, error)

DeleteDentryById deletes a dentry by Id

func (*DentryService) DeleteDentryByPrefix

func (s *DentryService) DeleteDentryByPrefix(ctx context.Context, req *pb.DeleteDentryByPrefixRequest) (*pb.DeleteDentryByPrefixResponse, error)

DeleteDentryByPrefix deletes dentry by prefix

func (*DentryService) Dentries

func (n *DentryService) Dentries(ctx context.Context, req *pb.DentriesRequest) (*pb.DentriesResponse, error)

Dentries returns a list of dentries for a delegation table

func (*DentryService) PutDentry

func (s *DentryService) PutDentry(ctx context.Context, req *pb.PutDentryRequest) (*pb.PutDentryResponse, error)

PutDentry creates or updates a dentry

func (*DentryService) PutService

func (s *DentryService) PutService(ctx context.Context, req *pb.PutServiceRequest) (*pb.PutServiceResponse, error)

PutService creates or updates a service

func (*DentryService) RegisterWithServer

func (ds *DentryService) RegisterWithServer(srv *grpc.Server)

func (*DentryService) RouteToVersion

func (s *DentryService) RouteToVersion(ctx context.Context, req *pb.RouteToVersionRequest) (*pb.RouteToVersionResponse, error)

RouteToVersion routes a service to a specified version

type ServiceSelectorDentryPutter

type ServiceSelectorDentryPutter interface {
	store.ServiceSelector
	store.DentryPutter
}