zbc

Jun 1, 2022

Changes in this version

type ClientConfig

+ UserAgent string

Jul 6, 2021

Changes in this version

+ const DefaultAddressHost

+ const DefaultAddressPort

+ const GatewayHostEnvVar

+ const GatewayPortEnvVar

May 10, 2021

Changes in this version

+ const CaCertificatePath

+ const DefaultKeepAlive

+ const DefaultOAuthCacheFile

+ const DefaultOAuthCacheFileDir

+ const DefaultRequestTimeout

+ const ErrFileNotFound

+ const ErrOAuthCredentialsCacheFolderIsNotDir

+ const ErrOAuthCredentialsCacheIsDir

+ const GatewayAddressEnvVar

+ const InsecureEnvVar

+ const KeepAliveEnvVar

+ const OAuthAuthorizationUrlEnvVar

+ const OAuthCachePathEnvVar

+ const OAuthClientIdEnvVar

+ const OAuthClientSecretEnvVar

+ const OAuthDefaultAuthzURL

+ const OAuthDefaultRequestTimeout

+ const OAuthRequestTimeoutEnvVar

+ const OAuthTokenAudienceEnvVar

+ var DefaultOauthYamlCachePath = getDefaultOAuthYamlCredentialsCachePath()

+ type Client interface

+ Close func() error

+ NewActivateJobsCommand func() commands.ActivateJobsCommandStep1

+ NewCancelInstanceCommand func() commands.CancelInstanceStep1

+ NewCompleteJobCommand func() commands.CompleteJobCommandStep1

+ NewCreateInstanceCommand func() commands.CreateInstanceCommandStep1

+ NewDeployProcessCommand func() *commands.DeployCommand

+ NewFailJobCommand func() commands.FailJobCommandStep1

+ NewJobWorker func() worker.JobWorkerBuilderStep1

+ NewPublishMessageCommand func() commands.PublishMessageCommandStep1

+ NewResolveIncidentCommand func() commands.ResolveIncidentCommandStep1

+ NewSetVariablesCommand func() commands.SetVariablesCommandStep1

+ NewThrowErrorCommand func() commands.ThrowErrorCommandStep1

+ NewTopologyCommand func() *commands.TopologyCommand

+ NewUpdateJobRetriesCommand func() commands.UpdateJobRetriesCommandStep1

+ func NewClient(config *ClientConfig) (Client, error)

+ type ClientConfig struct

+ CaCertificatePath string

+ CredentialsProvider CredentialsProvider

+ DialOpts []grpc.DialOption

+ GatewayAddress string

+ KeepAlive time.Duration

+ UsePlaintextConnection bool

+ type ClientImpl struct

+ func (c *ClientImpl) Close() error

+ func (c *ClientImpl) NewActivateJobsCommand() commands.ActivateJobsCommandStep1

+ func (c *ClientImpl) NewCancelInstanceCommand() commands.CancelInstanceStep1

+ func (c *ClientImpl) NewCompleteJobCommand() commands.CompleteJobCommandStep1

+ func (c *ClientImpl) NewCreateInstanceCommand() commands.CreateInstanceCommandStep1

+ func (c *ClientImpl) NewDeployProcessCommand() *commands.DeployCommand

+ func (c *ClientImpl) NewFailJobCommand() commands.FailJobCommandStep1

+ func (c *ClientImpl) NewJobWorker() worker.JobWorkerBuilderStep1

+ func (c *ClientImpl) NewPublishMessageCommand() commands.PublishMessageCommandStep1

+ func (c *ClientImpl) NewResolveIncidentCommand() commands.ResolveIncidentCommandStep1

+ func (c *ClientImpl) NewSetVariablesCommand() commands.SetVariablesCommandStep1

+ func (c *ClientImpl) NewThrowErrorCommand() commands.ThrowErrorCommandStep1

+ func (c *ClientImpl) NewTopologyCommand() *commands.TopologyCommand

+ func (c *ClientImpl) NewUpdateJobRetriesCommand() commands.UpdateJobRetriesCommandStep1

+ type CredentialsProvider interface

+ ApplyCredentials func(ctx context.Context, headers map[string]string) error

+ ShouldRetryRequest func(ctx context.Context, err error) bool

+ type Error string

+ func (e Error) Error() string

+ type OAuthCredentialsCache interface

+ Get func(audience string) *oauth2.Token

+ Refresh func() error

+ Update func(audience string, token *oauth2.Token) error

+ func NewOAuthYamlCredentialsCache(path string) (OAuthCredentialsCache, error)

+ type OAuthCredentialsProvider struct

+ Audience string

+ Cache OAuthCredentialsCache

+ TokenConfig *clientcredentials.Config

+ func NewOAuthCredentialsProvider(config *OAuthProviderConfig) (*OAuthCredentialsProvider, error)

+ func (p *OAuthCredentialsProvider) ApplyCredentials(ctx context.Context, headers map[string]string) error

+ func (p *OAuthCredentialsProvider) ShouldRetryRequest(ctx context.Context, err error) bool

+ type OAuthProviderConfig struct

+ Audience string

+ AuthorizationServerURL string

+ Cache OAuthCredentialsCache

+ ClientID string

+ ClientSecret string

+ Timeout time.Duration