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
	C2       int8
	C3       int16
	C4       proto.Nullable[int16]
	C5       proto.Nullable[string]
	Level    proto.Enum8
	IPv4     proto.Nullable[proto.IPv4]
	IPv6     proto.Nullable[proto.IPv6]
	TS       time.Time
	TSWithTZ time.Time
	TS64     time.Time
	F32      float32
	F64      float64
	LcStr    string
	StrArr   *[]string

	UUID         uuid.UUID
	UUIDNullable uuid.NullUUID

	// we are set this in the set_time action
	TS64Auto      time.Time
	TSRFC3339Nano time.Time
}

func (*Sample) MarshalJSON

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