outputs

Documentation

Index

• Constants
• Variables
• type Client
  • func NewClient(defaultEndpointURL string, mutualTLSEnabled bool, checkCert bool, ...) (*Client, error)
  • func (c *Client) AddHeader(key, value string)
  • func (c *Client) BasicAuth(username, password string)
  • func (c *Client) OpenSearchPost(payloadStr string)
  • func (c *Client) Post(payload string) error
• type Governor
  • func IntializeGovernor(payload string, config v1alpha1.ExportConfig) Governor
  • func (g *Governor) Post()
• type Header

Constants

const (
	DefaultContentType          = "application/json; charset=utf-8"
	ContentTypeHeaderKey        = "Content-Type"
	AuthorizationHeaderKey      = "Authorization"
	UserAgentHeaderKey          = "User-Agent"
	UserAgentHeaderValue        = "Narrows"
	MutualTLSFilesPath          = "/tmp/NarrowsTlsFiles"
	MutualTLSClientCertFilename = "/client.crt"
	MutualTLSClientKeyFilename  = "/client.key"
	MutualTLSCaCertFilename     = "/ca.crt"
)

Variables

var ErrClientCreation = errors.New("client creation error")

ErrClientCreation is returned if client can't be created

Types

type Client

type Client struct {
	EndpointURL      *url.URL
	MutualTLSEnabled bool
	CheckCert        bool
	HeaderList       []Header
	ContentType      string
	Config           *v1alpha1.ExportConfig
}

Client communicates with the different API.

func NewClient

func NewClient(defaultEndpointURL string, mutualTLSEnabled bool, checkCert bool, config *v1alpha1.ExportConfig) (*Client, error)

NewClient returns a new output.Client

func (*Client) AddHeader

func (c *Client) AddHeader(key, value string)

AddHeader adds an HTTP Header to the Client.

func (*Client) BasicAuth

func (c *Client) BasicAuth(username, password string)

BasicAuth adds an HTTP Basic Authentication compliant header to the Client.

func (*Client) OpenSearchPost

func (c *Client) OpenSearchPost(payloadStr string)

OpenSearchPost posts event to OpenSearch

func (*Client) Post

func (c *Client) Post(payload string) error

Post sends payload by the client object

type Governor

type Governor struct {
	Payload string
	Config  v1alpha1.ExportConfig
}

func IntializeGovernor

func IntializeGovernor(payload string, config v1alpha1.ExportConfig) Governor

func (*Governor) Post

func (g *Governor) Post()

Post posts event to GovernorAPI

type Header

type Header struct {
	Key   string
	Value string
}

Header to add to the client before sending the request