edp

Documentation

Index

• Variables
• type Client
  • func NewClient(c *Config, httpClient *http.Client, eventsChannel <-chan *[]byte, ...) *Client
  • func (c *Client) Run(parentCtx context.Context, parentwg *sync.WaitGroup)
  • func (c *Client) Write(parentctx context.Context, data *[]byte, logger *zap.SugaredLogger) error
• type Config

Variables

var (
	ErrEventInvalidRequest    = errors.New("invalid request")
	ErrEventMissingParameters = errors.New("namespace, dataStream or dataTenant not found")
	ErrEventUnknown           = errors.New("unknown error")
	ErrEventUnmarshal         = errors.New("unmarshal error")
	ErrEventHTTPRequest       = errors.New("HTTP request error")
)

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(c *Config, httpClient *http.Client, eventsChannel <-chan *[]byte, logger *zap.SugaredLogger) *Client

func (*Client) Run

func (c *Client) Run(parentCtx context.Context, parentwg *sync.WaitGroup)

func (*Client) Write

func (c *Client) Write(parentctx context.Context, data *[]byte, logger *zap.SugaredLogger) error

Write sends a batch of samples(json) to EDP

type Config

type Config struct {
	URL               string        `kong:"help='EDP base URL',env='EDP_URL',default='https://input.yevents.io',required=true"`
	Token             string        `kong:"help='EDP source token',placeholder='SECRET',env='EDP_TOKEN',required=true"`
	Namespace         string        `kong:"help='EDP Namespace',env='EDP_NAMESPACE',required=true"`
	DataStream        string        `kong:"help='EDP data stream name',env='EDP_DATASTREAM_NAME',required=true"`
	DataStreamVersion string        `kong:"help='EDP data stream version',env='EDP_DATASTREAM_VERSION',required=true"`
	DataStreamEnv     string        `kong:"help='EDP data stream environment',env='EDP_DATASTREAM_ENV',required=true"`
	Timeout           time.Duration `kong:"help='Time limit for requests made by the EDP client',env='EDP_TIMEOUT',required=true,default='30s'"`
	Buffer            int           `kong:"help='Number of events that the buffer can have.',env='EDP_BUFFER',required=true,default=100"`
	Workers           int           `kong:"help='Number of workers to send metrics.',env='EDP_WORKERS',required=true,default=5"`
	EventRetry        int           `kong:"help='Number of retries for sending event.',env='EDP_RETRY',required=true,default=5"`
}