agent

Documentation

Index

• type Agent
  • func New(db string) (*Agent, error)
  • func (a *Agent) Close() (err error)
  • func (a *Agent) Query(ctx context.Context, w io.Writer, q string) (err error)
  • func (a *Agent) Write(p []byte) (n int, err error)

Types

type Agent

type Agent struct {
	sync.Mutex

	Partition   time.Duration
	MaxFileSize int64

	KeyTimestamp string

	Stderr io.Writer
	// contains filtered or unexported fields
}

func New

func New(db string) (*Agent, error)

func (*Agent) Close

func (a *Agent) Close() (err error)

func (*Agent) Query

func (a *Agent) Query(ctx context.Context, w io.Writer, q string) (err error)

func (*Agent) Write

func (a *Agent) Write(p []byte) (n int, err error)