file_clickhouse

Documentation

Index

• type Config
  • func (c *Config) Configure(t *testing.T, conf *cfg.Config, pipelineName string)
  • func (c *Config) Send(t *testing.T)
  • func (c *Config) Validate(t *testing.T)
• type Sample
  • func (s *Sample) MarshalJSON() ([]byte, error)

Types

type Config

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

func (*Config) Configure

func (c *Config) Configure(t *testing.T, conf *cfg.Config, pipelineName string)

func (*Config) Send

func (c *Config) Send(t *testing.T)

func (*Config) Validate

func (c *Config) Validate(t *testing.T)

type Sample

type Sample struct {
	C1       json.RawMessage            `json:"c1"`
	C2       int8                       `json:"c2"`
	C3       int16                      `json:"c3"`
	C4       proto.Nullable[int16]      `json:"c4"`
	C5       proto.Nullable[string]     `json:"c5"`
	Level    proto.Enum8                `json:"level"`
	IPv4     proto.Nullable[proto.IPv4] `json:"ipv4"`
	IPv6     proto.Nullable[proto.IPv6] `json:"ipv6"`
	TS       time.Time                  `json:"ts"`
	TSWithTZ time.Time                  `json:"ts_with_tz"`
	TS64     time.Time                  `json:"ts_64"`
	F32      float32                    `json:"f32"`
	F64      float64                    `json:"f64"`

	// we are set this in the set_time action
	TS64Auto      time.Time `json:"ts_64_auto"`
	TSRFC3339Nano time.Time `json:"ts_rfc3339nano"`
}

func (*Sample) MarshalJSON

func (s *Sample) MarshalJSON() ([]byte, error)