integrationv1

Documentation

Index

• type AWSOIDCService
  • func NewAWSOIDCService(cfg *AWSOIDCServiceConfig) (*AWSOIDCService, error)
  • func (s *AWSOIDCService) ListDatabases(ctx context.Context, req *integrationpb.ListDatabasesRequest) (*integrationpb.ListDatabasesResponse, error)
• type AWSOIDCServiceConfig
  • func (s *AWSOIDCServiceConfig) CheckAndSetDefaults() error
• type Cache
• type KeyStoreManager
• type Service
  • func NewService(cfg *ServiceConfig) (*Service, error)
  • func (s *Service) CreateIntegration(ctx context.Context, req *integrationpb.CreateIntegrationRequest) (*types.IntegrationV1, error)
  • func (s *Service) DeleteAllIntegrations(ctx context.Context, _ *integrationpb.DeleteAllIntegrationsRequest) (*emptypb.Empty, error)
  • func (s *Service) DeleteIntegration(ctx context.Context, req *integrationpb.DeleteIntegrationRequest) (*emptypb.Empty, error)
  • func (s *Service) GenerateAWSOIDCToken(ctx context.Context, _ *integrationpb.GenerateAWSOIDCTokenRequest) (*integrationpb.GenerateAWSOIDCTokenResponse, error)
  • func (s *Service) GetIntegration(ctx context.Context, req *integrationpb.GetIntegrationRequest) (*types.IntegrationV1, error)
  • func (s *Service) ListIntegrations(ctx context.Context, req *integrationpb.ListIntegrationsRequest) (*integrationpb.ListIntegrationsResponse, error)
  • func (s *Service) UpdateIntegration(ctx context.Context, req *integrationpb.UpdateIntegrationRequest) (*types.IntegrationV1, error)
• type ServiceConfig
  • func (s *ServiceConfig) CheckAndSetDefaults() error

Types

type AWSOIDCService

type AWSOIDCService struct {
	integrationpb.UnimplementedAWSOIDCServiceServer
	// contains filtered or unexported fields
}

AWSOIDCService implements the teleport.integration.v1.AWSOIDCService RPC service.

func NewAWSOIDCService

func NewAWSOIDCService(cfg *AWSOIDCServiceConfig) (*AWSOIDCService, error)

NewAWSOIDCService returns a new AWSOIDCService.

func (*AWSOIDCService) ListDatabases

func (s *AWSOIDCService) ListDatabases(ctx context.Context, req *integrationpb.ListDatabasesRequest) (*integrationpb.ListDatabasesResponse, error)

ListIntegrations returns a paginated list of Databases.

type AWSOIDCServiceConfig

type AWSOIDCServiceConfig struct {
	IntegrationService *Service
	Authorizer         authz.Authorizer
	Logger             *logrus.Entry
}

AWSOIDCServiceConfig holds configuration options for the AWSOIDC Integration gRPC service.

func (*AWSOIDCServiceConfig) CheckAndSetDefaults

func (s *AWSOIDCServiceConfig) CheckAndSetDefaults() error

CheckAndSetDefaults checks the AWSOIDCServiceConfig fields and returns an error if a required param is not provided. Authorizer and IntegrationService are required params.

type Cache

type Cache interface {
	// GetClusterName returns local cluster name of the current auth server
	GetClusterName(...services.MarshalOption) (types.ClusterName, error)

	// GetCertAuthority returns certificate authority by given id. Parameter loadSigningKeys
	// controls if signing keys are loaded
	GetCertAuthority(ctx context.Context, id types.CertAuthID, loadSigningKeys bool) (types.CertAuthority, error)

	// GetProxies returns a list of registered proxies.
	GetProxies() ([]types.Server, error)

	// IntegrationsGetter defines methods to access Integration resources.
	services.IntegrationsGetter
}

Cache is the subset of the cached resources that the Service queries.

type KeyStoreManager

type KeyStoreManager interface {
	// GetJWTSigner selects a usable JWT keypair from the given keySet and returns a [crypto.Signer].
	GetJWTSigner(ctx context.Context, ca types.CertAuthority) (crypto.Signer, error)
}

KeyStoreManager defines methods to get signers using the server's keystore.

type Service

type Service struct {
	integrationpb.UnimplementedIntegrationServiceServer
	// contains filtered or unexported fields
}

Service implements the teleport.integration.v1.IntegrationService RPC service.

func NewService

func NewService(cfg *ServiceConfig) (*Service, error)

NewService returns a new Integrations gRPC service.

func (*Service) CreateIntegration

func (s *Service) CreateIntegration(ctx context.Context, req *integrationpb.CreateIntegrationRequest) (*types.IntegrationV1, error)

CreateIntegration creates a new Okta import rule resource.

func (*Service) DeleteAllIntegrations

func (s *Service) DeleteAllIntegrations(ctx context.Context, _ *integrationpb.DeleteAllIntegrationsRequest) (*emptypb.Empty, error)

DeleteAllIntegrations removes all Integration resources.

func (*Service) DeleteIntegration

func (s *Service) DeleteIntegration(ctx context.Context, req *integrationpb.DeleteIntegrationRequest) (*emptypb.Empty, error)

DeleteIntegration removes the specified Integration resource.

func (*Service) GenerateAWSOIDCToken

func (s *Service) GenerateAWSOIDCToken(ctx context.Context, _ *integrationpb.GenerateAWSOIDCTokenRequest) (*integrationpb.GenerateAWSOIDCTokenResponse, error)

GenerateAWSOIDCToken generates a token to be used when executing an AWS OIDC Integration action.

func (*Service) GetIntegration

func (s *Service) GetIntegration(ctx context.Context, req *integrationpb.GetIntegrationRequest) (*types.IntegrationV1, error)

GetIntegration returns the specified Integration resource.

func (*Service) ListIntegrations

func (s *Service) ListIntegrations(ctx context.Context, req *integrationpb.ListIntegrationsRequest) (*integrationpb.ListIntegrationsResponse, error)

ListIntegrations returns a paginated list of all Integration resources.

func (*Service) UpdateIntegration

func (s *Service) UpdateIntegration(ctx context.Context, req *integrationpb.UpdateIntegrationRequest) (*types.IntegrationV1, error)

UpdateIntegration updates an existing Okta import rule resource.

type ServiceConfig

type ServiceConfig struct {
	Authorizer      authz.Authorizer
	Backend         services.Integrations
	Cache           Cache
	KeyStoreManager KeyStoreManager
	Logger          *logrus.Entry
	Clock           clockwork.Clock
}

ServiceConfig holds configuration options for the Integration gRPC service.

func (*ServiceConfig) CheckAndSetDefaults

func (s *ServiceConfig) CheckAndSetDefaults() error

CheckAndSetDefaults checks the ServiceConfig fields and returns an error if a required param is not provided. Authorizer, Cache and Backend are required params