Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HTTPClient ¶
type HTTPClient struct {
Name string
Config HTTPClientConfig
// contains filtered or unexported fields
}
func NewHTTPClient ¶
func NewHTTPClient(name string, cfg HTTPClientConfig) *HTTPClient
func (*HTTPClient) Fetch ¶
func (t *HTTPClient) Fetch(method string, host string, data []byte, headers map[string][]string) chan interfaces.IClientResponse
func (*HTTPClient) Init ¶
func (t *HTTPClient) Init(app interfaces.IEngine) error
func (*HTTPClient) Stop ¶
func (t *HTTPClient) Stop() error
func (*HTTPClient) String ¶
func (t *HTTPClient) String() string
type HTTPClientConfig ¶
type HTTPClientConfig struct {
RetryCount int `yaml:"retry_count"`
}
type KafkaClient ¶
type KafkaClient struct {
Name string
Config KafkaClientConfig
// contains filtered or unexported fields
}
func NewKafkaClient ¶
func NewKafkaClient(name string, cfg KafkaClientConfig) *KafkaClient
func (*KafkaClient) Fetch ¶
func (t *KafkaClient) Fetch(_ string, topic string, data []byte, headers map[string][]string) chan interfaces.IClientResponse
func (*KafkaClient) Init ¶
func (t *KafkaClient) Init(app interfaces.IEngine) error
func (*KafkaClient) Stop ¶
func (t *KafkaClient) Stop() error
func (*KafkaClient) String ¶
func (t *KafkaClient) String() string
type KafkaClientConfig ¶
type Response ¶
func (*Response) GetRetries ¶
Click to show internal directories.
Click to hide internal directories.