Documentation
¶
Index ¶
- func GetAdditionalAdminClientConfigOptions(cfg Config) []grpc.DialOption
- func InitializeAdminClient(ctx context.Context, cfg Config) service.AdminServiceClient
- func InitializeAdminClientFromConfig(ctx context.Context) (service.AdminServiceClient, error)
- func InitializeMockAdminClient() service.AdminServiceClient
- func NewAdminClient(ctx context.Context, conn *grpc.ClientConn) service.AdminServiceClient
- func NewAdminConnection(_ context.Context, cfg Config) (*grpc.ClientConn, error)
- type Config
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetAdditionalAdminClientConfigOptions ¶
func GetAdditionalAdminClientConfigOptions(cfg Config) []grpc.DialOption
func InitializeAdminClient ¶
func InitializeAdminClient(ctx context.Context, cfg Config) service.AdminServiceClient
Create an AdminClient with a shared Admin connection for the process
func InitializeAdminClientFromConfig ¶
func InitializeAdminClientFromConfig(ctx context.Context) (service.AdminServiceClient, error)
func InitializeMockAdminClient ¶
func InitializeMockAdminClient() service.AdminServiceClient
func NewAdminClient ¶
func NewAdminClient(ctx context.Context, conn *grpc.ClientConn) service.AdminServiceClient
func NewAdminConnection ¶
Types ¶
type Config ¶
type Config struct {
Endpoint config.URL `json:"endpoint" pflag:",For admin types, specify where the uri of the service is located."`
UseInsecureConnection bool `json:"insecure" pflag:",Use insecure connection."`
MaxBackoffDelay config.Duration `json:"maxBackoffDelay" pflag:",Max delay for grpc backoff"`
PerRetryTimeout config.Duration `json:"perRetryTimeout" pflag:",gRPC per retry timeout"`
MaxRetries int `json:"maxRetries" pflag:",Max number of gRPC retries"`
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.