pool

package
v2.21.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 8, 2024 License: Apache-2.0 Imports: 34 Imported by: 20

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetAppAuthProviderServiceClient 

func GetAppAuthProviderServiceClient(id string, opts ...Option) (applicationauth.ApplicationsAPIClient, error)

GetAppAuthProviderServiceClient returns a new AppAuthProviderServiceClient.

func GetAppProviderClient 

func GetAppProviderClient(id string, opts ...Option) (appprovider.ProviderAPIClient, error)

GetAppProviderClient returns a new AppRegistryClient.

func GetAppRegistryClient 

func GetAppRegistryClient(id string, opts ...Option) (appregistry.RegistryAPIClient, error)

GetAppRegistryClient returns a new AppRegistryClient.

func GetAuthProviderServiceClient 

func GetAuthProviderServiceClient(id string, opts ...Option) (authprovider.ProviderAPIClient, error)

GetAuthProviderServiceClient returns a new AuthProviderServiceClient.

func GetAuthRegistryServiceClient 

func GetAuthRegistryServiceClient(id string, opts ...Option) (authregistry.RegistryAPIClient, error)

GetAuthRegistryServiceClient returns a new AuthRegistryServiceClient.

func GetDataTxClient 

func GetDataTxClient(id string, opts ...Option) (datatx.TxAPIClient, error)

GetDataTxClient returns a new DataTxClient.

func GetGatewayServiceClient 

func GetGatewayServiceClient(id string, opts ...Option) (gateway.GatewayAPIClient, error)

GetGatewayServiceClient returns a GatewayServiceClient.

func GetGroupProviderServiceClient 

func GetGroupProviderServiceClient(id string, opts ...Option) (group.GroupAPIClient, error)

GetGroupProviderServiceClient returns a GroupProviderServiceClient.

func GetOCMCoreClient 

func GetOCMCoreClient(id string, opts ...Option) (ocmcore.OcmCoreAPIClient, error)

GetOCMCoreClient returns a new OCMCoreClient.

func GetOCMInviteManagerClient 

func GetOCMInviteManagerClient(id string, opts ...Option) (invitepb.InviteAPIClient, error)

GetOCMInviteManagerClient returns a new OCMInviteManagerClient.

func GetOCMProviderAuthorizerClient 

func GetOCMProviderAuthorizerClient(id string, opts ...Option) (ocmprovider.ProviderAPIClient, error)

GetOCMProviderAuthorizerClient returns a new OCMProviderAuthorizerClient.

func GetOCMShareProviderClient 

func GetOCMShareProviderClient(id string, opts ...Option) (ocm.OcmAPIClient, error)

GetOCMShareProviderClient returns a new OCMShareProviderClient.

func GetPermissionsClient 

func GetPermissionsClient(id string, opts ...Option) (permissions.PermissionsAPIClient, error)

GetPermissionsClient returns a new PermissionsClient.

func GetPreferencesClient 

func GetPreferencesClient(id string, opts ...Option) (preferences.PreferencesAPIClient, error)

GetPreferencesClient returns a new PreferencesClient.

func GetPublicShareProviderClient 

func GetPublicShareProviderClient(id string, opts ...Option) (link.LinkAPIClient, error)

GetPublicShareProviderClient returns a new PublicShareProviderClient.

func GetStorageProviderServiceClient 

func GetStorageProviderServiceClient(id string, opts ...Option) (storageprovider.ProviderAPIClient, error)

GetStorageProviderServiceClient returns a StorageProviderServiceClient.

func GetStorageRegistryClient 

func GetStorageRegistryClient(id string, opts ...Option) (storageregistry.RegistryAPIClient, error)

GetStorageRegistryClient returns a new StorageRegistryClient.

func GetUserProviderServiceClient 

func GetUserProviderServiceClient(id string, opts ...Option) (user.UserAPIClient, error)

GetUserProviderServiceClient returns a UserProviderServiceClient.

func GetUserShareProviderClient 

func GetUserShareProviderClient(id string, opts ...Option) (collaboration.CollaborationAPIClient, error)

GetUserShareProviderClient returns a new UserShareProviderClient.

func NewConn 

func NewConn(address string, opts ...Option) (*grpc.ClientConn, error)

NewConn creates a new connection to a grpc server with open census tracing support. TODO(labkode): make grpc tls configurable.

func RemoveSelector added in v2.15.0 

func RemoveSelector(id string)

RemoveSelector removes given id from the selectors map.

Types

type ClientOptions added in v2.11.0 

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

ClientOptions represent additional options (e.g. tls settings) for the grpc clients

type Option added in v2.11.0 

type Option func(opts *ClientOptions)

Option is used to pass client options

func WithRegistry added in v2.15.0 

func WithRegistry(v registry.Registry) Option

WithRegistry allows to set the registry for service lookup

func WithTLSCACert added in v2.11.0 

func WithTLSCACert(v string) Option

WithTLSCACert allows to set the CA Certificate for grpc clients

func WithTLSMode added in v2.11.0 

func WithTLSMode(v TLSMode) Option

WithTLSMode allows to set the TLSMode option for grpc clients

func WithTracerProvider added in v2.14.0 

func WithTracerProvider(v trace.TracerProvider) Option

WithTracerProvider allows to set the opentelemetry tracer provider for grpc clients

type Selectable added in v2.15.0 

type Selectable[T any] interface {
	Next(opts ...Option) (T, error)
}

type Selector added in v2.15.0 

type Selector[T any] struct {
	// contains filtered or unexported fields
}

func AppProviderSelector added in v2.15.0 

func AppProviderSelector(id string, options ...Option) (*Selector[appProvider.ProviderAPIClient], error)

AppProviderSelector returns a Selector[appProvider.ProviderAPIClient].

func AppRegistrySelector added in v2.15.0 

func AppRegistrySelector(id string, options ...Option) (*Selector[appRegistry.RegistryAPIClient], error)

AppRegistrySelector returns a Selector[appRegistry.RegistryAPIClient].

func AuthApplicationSelector added in v2.15.0 

func AuthApplicationSelector(id string, options ...Option) (*Selector[authApplication.ApplicationsAPIClient], error)

AuthApplicationSelector returns a Selector[authApplication.ApplicationsAPIClient].

func AuthProviderSelector added in v2.15.0 

func AuthProviderSelector(id string, options ...Option) (*Selector[authProvider.ProviderAPIClient], error)

AuthProviderSelector returns a Selector[authProvider.RegistryAPIClient].

func AuthRegistrySelector added in v2.15.0 

func AuthRegistrySelector(id string, options ...Option) (*Selector[authRegistry.RegistryAPIClient], error)

AuthRegistrySelector returns a Selector[authRegistry.RegistryAPIClient].

func GatewaySelector added in v2.15.0 

func GatewaySelector(id string, options ...Option) (*Selector[gateway.GatewayAPIClient], error)

GatewaySelector returns a Selector[gateway.GatewayAPIClient].

func GetSelector added in v2.15.0 

func GetSelector[T any](k string, id string, f func(cc *grpc.ClientConn) T, options ...Option) *Selector[T]

func IdentityGroupSelector added in v2.15.0 

func IdentityGroupSelector(id string, options ...Option) (*Selector[identityGroup.GroupAPIClient], error)

IdentityGroupSelector returns a Selector[identityGroup.GroupAPIClient].

func IdentityUserSelector added in v2.15.0 

func IdentityUserSelector(id string, options ...Option) (*Selector[identityUser.UserAPIClient], error)

IdentityUserSelector returns a Selector[identityUser.UserAPIClient].

func OCMCoreSelector added in v2.15.0 

func OCMCoreSelector(id string, options ...Option) (*Selector[ocmCore.OcmCoreAPIClient], error)

OCMCoreSelector returns a Selector[ocmCore.OcmCoreAPIClient].

func OCMInviteSelector added in v2.15.0 

func OCMInviteSelector(id string, options ...Option) (*Selector[ocmInvite.InviteAPIClient], error)

OCMInviteSelector returns a Selector[ocmInvite.InviteAPIClient].

func OCMProviderSelector added in v2.15.0 

func OCMProviderSelector(id string, options ...Option) (*Selector[ocmProvider.ProviderAPIClient], error)

OCMProviderSelector returns a Selector[storageRegistry.RegistryAPIClient].

func PermissionsSelector added in v2.15.0 

func PermissionsSelector(id string, options ...Option) (*Selector[permissions.PermissionsAPIClient], error)

PermissionsSelector returns a Selector[permissions.PermissionsAPIClient].

func PreferencesSelector added in v2.15.0 

func PreferencesSelector(id string, options ...Option) (*Selector[preferences.PreferencesAPIClient], error)

PreferencesSelector returns a Selector[preferences.PreferencesAPIClient].

func SharingCollaborationSelector added in v2.15.0 

func SharingCollaborationSelector(id string, options ...Option) (*Selector[sharingCollaboration.CollaborationAPIClient], error)

SharingCollaborationSelector returns a Selector[sharingCollaboration.ApplicationsAPIClient].

func SharingLinkSelector added in v2.15.0 

func SharingLinkSelector(id string, options ...Option) (*Selector[sharingLink.LinkAPIClient], error)

SharingLinkSelector returns a Selector[sharingLink.LinkAPIClient].

func SharingOCMSelector added in v2.15.0 

func SharingOCMSelector(id string, options ...Option) (*Selector[sharingOCM.OcmAPIClient], error)

SharingOCMSelector returns a Selector[sharingOCM.OcmAPIClient].

func StorageProviderSelector added in v2.15.0 

func StorageProviderSelector(id string, options ...Option) (*Selector[storageProvider.ProviderAPIClient], error)

StorageProviderSelector returns a Selector[storageProvider.ProviderAPIClient].

func StorageRegistrySelector added in v2.15.0 

func StorageRegistrySelector(id string, options ...Option) (*Selector[storageRegistry.RegistryAPIClient], error)

StorageRegistrySelector returns a Selector[storageRegistry.RegistryAPIClient].

func TXSelector added in v2.15.0 

func TXSelector(id string, options ...Option) (*Selector[tx.TxAPIClient], error)

TXSelector returns a Selector[tx.TxAPIClient].

func (*Selector[T]) Next added in v2.15.0 

func (s *Selector[T]) Next(opts ...Option) (T, error)

type TLSMode added in v2.11.0 

type TLSMode int

TLSMode represents TLS mode for the clients 

const (
	// TLSOff completely disables transport security
	TLSOff TLSMode = iota
	// TLSOn enables transport security
	TLSOn
	// TLSInsecure enables transport security, but disables the verification of the
	// server certificate
	TLSInsecure
)

func StringToTLSMode added in v2.11.0 

func StringToTLSMode(m string) (TLSMode, error)

StringToTLSMode converts the supply string into the equivalent TLSMode constant

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.