agent

package
v0.25.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 2, 2024 License: MIT Imports: 16 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrUnknownSubscription = stderrors.New("unknown subscription")

	ErrFileFull = stderrors.New("file is full")
)

Functions

This section is empty.

Types

type Agent 

type Agent struct {
	KeyTimestamp string

	Partition time.Duration
	FileSize  int64
	BlockSize int64

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

func New 

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

func (*Agent) Query 

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

func (*Agent) Subscribe added in v0.22.1 

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

func (*Agent) Unsubscribe added in v0.22.1 

func (a *Agent) Unsubscribe(ctx context.Context, id int64) error

func (*Agent) Write 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.
JackTT - Gopher 🇻🇳