usp_file

Documentation

Index

• type FileAdapter
  • func NewFileAdapter(ctx context.Context, conf FileConfig) (*FileAdapter, chan struct{}, error)
  • func (a *FileAdapter) Close() error
• type FileConfig
  • func (c *FileConfig) Validate() error

Types

type FileAdapter

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

func NewFileAdapter

func NewFileAdapter(ctx context.Context, conf FileConfig) (*FileAdapter, chan struct{}, error)

func (*FileAdapter) Close

func (a *FileAdapter) Close() error

type FileConfig

type FileConfig struct {
	ClientOptions         uspclient.ClientOptions `json:"client_options" yaml:"client_options"`
	WriteTimeoutSec       uint64                  `json:"write_timeout_sec,omitempty" yaml:"write_timeout_sec,omitempty"`
	FilePath              string                  `json:"file_path" yaml:"file_path"`
	NoFollow              bool                    `json:"no_follow" yaml:"no_follow"`
	InactivityThreshold   int                     `json:"inactivity_threshold" yaml:"inactivity_threshold"`
	ReactivationThreshold int                     `json:"reactivation_threshold" yaml:"reactivation_threshold"`
	Backfill              bool                    `json:"backfill" yaml:"backfill"`
	SerializeFiles        bool                    `json:"serialize_files" yaml:"serialize_files"`
	Poll                  bool                    `json:"poll" yaml:"poll"`
	MultiLineJSON         bool                    `json:"multi_line_json" yaml:"multi_line_json"`
}

func (*FileConfig) Validate

func (c *FileConfig) Validate() error