client

Documentation

Index

• type GrpcClient
  • func NewGrpcClient(name string, cfg GrpcClientConfig) *GrpcClient
  • func (t *GrpcClient) GetClient() *grpc.ClientConn
  • func (t *GrpcClient) Init(app interfaces.IEngine) error
  • func (t *GrpcClient) Stop() error
  • func (t *GrpcClient) String() string
• type GrpcClientConfig
• type HTTPClient
  • func NewHTTPClient(name string, cfg HTTPClientConfig) *HTTPClient
  • func (t *HTTPClient) Fetch(ctx context.Context, method string, host string, data []byte, ...) chan interfaces.IClientResponse
  • func (t *HTTPClient) Init(app interfaces.IEngine) error
  • func (t *HTTPClient) Stop() error
  • func (t *HTTPClient) String() string
• type HTTPClientConfig
• type KafkaClient
  • func NewKafkaClient(name string, cfg KafkaClientConfig) *KafkaClient
  • func (t *KafkaClient) Fetch(ctx context.Context, _ string, topic string, data []byte, ...) chan interfaces.IClientResponse
  • func (t *KafkaClient) Init(app interfaces.IEngine) error
  • func (t *KafkaClient) Stop() error
  • func (t *KafkaClient) String() string
• type KafkaClientConfig
• type Mock
  • func (t *Mock) Init(_ interfaces.IEngine) error
  • func (t *Mock) Stop() error
  • func (t *Mock) String() string
• type Response
  • func (t *Response) Error() error
  • func (t *Response) GetBody() ([]byte, error)
  • func (t *Response) GetHeader() map[string][]string
  • func (t *Response) GetLazyBody() io.Reader
  • func (t *Response) GetRetries() int

Types

type GrpcClient

type GrpcClient struct {
	Name   string
	Config GrpcClientConfig
	// contains filtered or unexported fields
}

func NewGrpcClient

func NewGrpcClient(name string, cfg GrpcClientConfig) *GrpcClient

func (*GrpcClient) GetClient

func (t *GrpcClient) GetClient() *grpc.ClientConn

func (*GrpcClient) Init

func (t *GrpcClient) Init(app interfaces.IEngine) error

func (*GrpcClient) Stop

func (t *GrpcClient) Stop() error

func (*GrpcClient) String

func (t *GrpcClient) String() string

type GrpcClientConfig

type GrpcClientConfig struct {
	Url string `yaml:"url"`
}

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(ctx context.Context, 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(ctx context.Context, _ 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 KafkaClientConfig struct {
	Hosts      string `yaml:"hosts"`
	Username   string `yaml:"username"`
	Password   string `yaml:"password"`
	RetryCount int    `yaml:"retry_count"`
}

type Mock

type Mock struct {
	Name string
}

func (*Mock) Init

func (t *Mock) Init(_ interfaces.IEngine) error

func (*Mock) Stop

func (t *Mock) Stop() error

func (*Mock) String

func (t *Mock) String() string

type Response

type Response struct {
	Body       io.Reader
	Header     map[string][]string
	Err        error
	RetryCount int
}

func (*Response) Error

func (t *Response) Error() error

func (*Response) GetBody

func (t *Response) GetBody() ([]byte, error)

func (*Response) GetHeader

func (t *Response) GetHeader() map[string][]string

func (*Response) GetLazyBody

func (t *Response) GetLazyBody() io.Reader

func (*Response) GetRetries

func (t *Response) GetRetries() int