connectorbuilder

Documentation

Index

• func NewConnector(ctx context.Context, in interface{}, opts ...Opt) (types.ConnectorServer, error)
• type AccountManager
• type ConnectorBuilder
• type CreateAccountResponse
• type CredentialManager
• type EventProvider
• type Opt
  • func WithMetricsHandler(h metrics.Handler) Opt
  • func WithTicketingEnabled() Opt
• type ResourceManager
• type ResourceProvisioner
• type ResourceProvisionerV2
• type ResourceSyncer
• type TicketManager

Functions

func NewConnector

func NewConnector(ctx context.Context, in interface{}, opts ...Opt) (types.ConnectorServer, error)

NewConnector creates a new ConnectorServer for a new resource.

Types

type AccountManager

type AccountManager interface {
	CreateAccount(ctx context.Context, accountInfo *v2.AccountInfo, credentialOptions *v2.CredentialOptions) (CreateAccountResponse, []*v2.PlaintextData, annotations.Annotations, error)
}

type ConnectorBuilder

type ConnectorBuilder interface {
	Metadata(ctx context.Context) (*v2.ConnectorMetadata, error)
	Validate(ctx context.Context) (annotations.Annotations, error)
	ResourceSyncers(ctx context.Context) []ResourceSyncer
}

type CreateAccountResponse

type CreateAccountResponse interface {
	proto.Message
	GetIsCreateAccountResult() bool
}

type CredentialManager

type CredentialManager interface {
	Rotate(ctx context.Context, resourceId *v2.ResourceId, credentialOptions *v2.CredentialOptions) ([]*v2.PlaintextData, annotations.Annotations, error)
}

type EventProvider

type EventProvider interface {
	ListEvents(ctx context.Context, earliestEvent *timestamppb.Timestamp, pToken *pagination.StreamToken) ([]*v2.Event, *pagination.StreamState, annotations.Annotations, error)
}

type Opt

type Opt func(b *builderImpl) error

func WithMetricsHandler

func WithMetricsHandler(h metrics.Handler) Opt

func WithTicketingEnabled

func WithTicketingEnabled() Opt

type ResourceManager

type ResourceManager interface {
	Create(ctx context.Context, resource *v2.Resource) (*v2.Resource, annotations.Annotations, error)
	Delete(ctx context.Context, resourceId *v2.ResourceId) (annotations.Annotations, error)
}

type ResourceProvisioner

type ResourceProvisioner interface {
	ResourceType(ctx context.Context) *v2.ResourceType
	Grant(ctx context.Context, resource *v2.Resource, entitlement *v2.Entitlement) (annotations.Annotations, error)
	Revoke(ctx context.Context, grant *v2.Grant) (annotations.Annotations, error)
}

type ResourceProvisionerV2

type ResourceProvisionerV2 interface {
	ResourceType(ctx context.Context) *v2.ResourceType
	Grant(ctx context.Context, resource *v2.Resource, entitlement *v2.Entitlement) ([]*v2.Grant, annotations.Annotations, error)
	Revoke(ctx context.Context, grant *v2.Grant) (annotations.Annotations, error)
}

type ResourceSyncer

type ResourceSyncer interface {
	ResourceType(ctx context.Context) *v2.ResourceType
	List(ctx context.Context, parentResourceID *v2.ResourceId, pToken *pagination.Token) ([]*v2.Resource, string, annotations.Annotations, error)
	Entitlements(ctx context.Context, resource *v2.Resource, pToken *pagination.Token) ([]*v2.Entitlement, string, annotations.Annotations, error)
	Grants(ctx context.Context, resource *v2.Resource, pToken *pagination.Token) ([]*v2.Grant, string, annotations.Annotations, error)
}

type TicketManager

type TicketManager interface {
	GetTicket(ctx context.Context, ticketId string) (*v2.Ticket, annotations.Annotations, error)
	CreateTicket(ctx context.Context, ticket *v2.Ticket, schema *v2.TicketSchema) (*v2.Ticket, annotations.Annotations, error)
	GetTicketSchema(ctx context.Context, schemaID string) (*v2.TicketSchema, annotations.Annotations, error)
	ListTicketSchemas(ctx context.Context, pToken *pagination.Token) ([]*v2.TicketSchema, string, annotations.Annotations, error)
}