destination

type ChannelDestination struct {
	Output chan<- *optimusv1.LogEvent
}

type Closer = func() error

type Deliverer = func(context.Context, *optimusv1.LogEvent) error

type Destination struct {
	ID            string
	Kind          string
	BufferSize    int
	Subscriptions []string
	Subscriber    pubsub.Subscriber
	// contains filtered or unexported fields
}

type DestinationProcessor interface {
	Setup() error
	Deliver(context.Context, *optimusv1.LogEvent) error
	Close() error
}

type FileDestination struct {
	Path string `hcl:"path"`
	// contains filtered or unexported fields
}

type Header struct {
	Key   string `hcl:"key"`
	Value string `hcl:"value"`
	Path  string `hcl:"path"`
}

type HttpDestination struct {
	Timeout      time.Duration `hcl:"timeout,optional"`
	Retries      int           `hcl:"retries,optional"`
	Endpoint     string        `hcl:"endpoint"`
	Method       string        `hcl:"http_method,optional"`
	Headers      []Header      `hcl:"headers,optional"`
	BatchSize    int           `hcl:"batch_size,optional"`
	BatchTimeout time.Duration `hcl:"batch_timeout,optional"`
	// contains filtered or unexported fields
}

type Initializer = func() error

type StdOutDestination struct {
	Writer io.Writer
	// contains filtered or unexported fields
}