ingressclient

Documentation

Index

• Constants
• type IngressClient
  • func NewIngressClient(ingressAddress string, tlsConfig *tls.Config, opts ...IngressClientOption) (*IngressClient, error)
  • func (c *IngressClient) Close()
  • func (c *IngressClient) Write(points []*rpc.Point) error
• type IngressClientOption
  • func WithDialTimeout(timeout time.Duration) IngressClientOption
  • func WithIngressClientLogger(log *logger.Logger) IngressClientOption

Constants

const (
	MAX_BATCH_SIZE_IN_BYTES           = 32 * 1024
	MAX_INGRESS_PAYLOAD_SIZE_IN_BYTES = 2 * MAX_BATCH_SIZE_IN_BYTES
)

Types

type IngressClient

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

func NewIngressClient

func NewIngressClient(ingressAddress string, tlsConfig *tls.Config, opts ...IngressClientOption) (*IngressClient, error)

func (*IngressClient) Close

func (c *IngressClient) Close()

func (*IngressClient) Write

func (c *IngressClient) Write(points []*rpc.Point) error

type IngressClientOption

type IngressClientOption func(*IngressClient)

func WithDialTimeout

func WithDialTimeout(timeout time.Duration) IngressClientOption

func WithIngressClientLogger

func WithIngressClientLogger(log *logger.Logger) IngressClientOption