edp

package

v0.0.0-...-ddad2a0 Latest Latest Go to latest Published: Jul 2, 2020 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kyma-incubator/compass

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

Constants ¶

This section is empty.

Variables ¶

View Source

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")
)

Functions ¶

This section is empty.

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"`
}

Source Files ¶

View all Source files

client.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL