pool_misrocervice_client

Documentation

Index

• func AppUserAgent(app app_context.Context) string
• func BaseUrlForService(service *pool.PoolServiceBinding, public ...bool) (string, error)
• type PoolMicroserviceClient
  • func NewPoolMicroserviceClient(defaultRole string, client ...PoolServiceClient) *PoolMicroserviceClient
  • func (p *PoolMicroserviceClient) Config() interface{}
  • func (p *PoolMicroserviceClient) Init(app app_with_pools.AppWithPools, configPath ...string) error
  • func (p *PoolMicroserviceClient) SetOverridePool(poolName string)
  • func (p *PoolMicroserviceClient) SetPropagateAuthUser(val bool)
  • func (p *PoolMicroserviceClient) SetPropagateContextId(val bool)
  • func (p *PoolMicroserviceClient) SetService(ctx op_context.Context, service *pool.PoolServiceBinding) error
  • func (p *PoolMicroserviceClient) Shutdown(ctx context.Context) error
• type PoolMicroserviceClientConfig
• type PoolServiceClient
• type RestApiPoolServiceClient
  • func (r *RestApiPoolServiceClient) InitForPoolService(httpClient *http_request.HttpClient, service *pool.PoolServiceBinding, ...) error

Functions

func AppUserAgent

func AppUserAgent(app app_context.Context) string

func BaseUrlForService

func BaseUrlForService(service *pool.PoolServiceBinding, public ...bool) (string, error)

Types

type PoolMicroserviceClient

type PoolMicroserviceClient struct {
	http_request.WithHttpClient
	PoolMicroserviceClientConfig
	PoolServiceClient
	// contains filtered or unexported fields
}

func NewPoolMicroserviceClient

func NewPoolMicroserviceClient(defaultRole string, client ...PoolServiceClient) *PoolMicroserviceClient

func (*PoolMicroserviceClient) Config

func (p *PoolMicroserviceClient) Config() interface{}

func (*PoolMicroserviceClient) Init

func (p *PoolMicroserviceClient) Init(app app_with_pools.AppWithPools, configPath ...string) error

func (*PoolMicroserviceClient) SetOverridePool

func (p *PoolMicroserviceClient) SetOverridePool(poolName string)

func (*PoolMicroserviceClient) SetPropagateAuthUser

func (p *PoolMicroserviceClient) SetPropagateAuthUser(val bool)

func (*PoolMicroserviceClient) SetPropagateContextId

func (p *PoolMicroserviceClient) SetPropagateContextId(val bool)

func (*PoolMicroserviceClient) SetService

func (p *PoolMicroserviceClient) SetService(ctx op_context.Context, service *pool.PoolServiceBinding) error

func (*PoolMicroserviceClient) Shutdown

func (p *PoolMicroserviceClient) Shutdown(ctx context.Context) error

type PoolMicroserviceClientConfig

type PoolMicroserviceClientConfig struct {
	POOL_SERVICE_ROLE string `validate:"required" vmessage:"Service role in the pool must be specified"`
}

type PoolServiceClient

type PoolServiceClient interface {
	api_client.Client
	InitForPoolService(httpClient *http_request.HttpClient, service *pool.PoolServiceBinding, clientAgent ...string) error
}

type RestApiPoolServiceClient

type RestApiPoolServiceClient struct {
	*rest_api_client.Client
}

func (*RestApiPoolServiceClient) InitForPoolService

func (r *RestApiPoolServiceClient) InitForPoolService(httpClient *http_request.HttpClient, service *pool.PoolServiceBinding, clientAgent ...string) error