logfwd

package
v0.0.0-...-b0bff92 Latest Latest
Warning

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

Go to latest
Published: Dec 7, 2021 License: AGPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FacadeCaller

type FacadeCaller interface {
	// FacadeCall is the same method as on base.FacadeCaller.
	FacadeCall(request string, params, response interface{}) error
}

FacadeCaller provides the functionality to call methods on a facade.

type LastSentClient

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

LastSentClient exposes the "last sent" methods of the LogForwarding API facade.

func NewLastSentClient

func NewLastSentClient(newFacadeCaller func(string) FacadeCaller) *LastSentClient

NewLastSentClient creates a new API client for the facade.

func (LastSentClient) GetLastSent

func (c LastSentClient) GetLastSent(ids []LastSentID) ([]LastSentResult, error)

GetLastSent makes a "GetLastSent" call on the facade and returns the results in the same order.

func (LastSentClient) SetLastSent

func (c LastSentClient) SetLastSent(reqs []LastSentInfo) ([]LastSentResult, error)

SetLastSent makes a "SetLastSent" call on the facade and returns the results in the same order.

type LastSentID

type LastSentID struct {
	// ModelTag identifies the model associated with the log record.
	Model names.ModelTag

	// Sink is the name of the log forwarding target to which a log
	// record was last sent.
	Sink string
}

LastSentID is the data that identifies a log forwarding "last sent" value. The controller has a mapping from a set of IDs to a record ID (for each ID). The record ID corresponds to the last log record that the specific log forwarding machinery sent to the identified "sink" (for a given model).

type LastSentInfo

type LastSentInfo struct {
	LastSentID

	// RecordID identifies the last log record that was forwarded
	// for a given model and sink.
	RecordID int64

	// RecordTimestamp identifies the last log record that was forwarded
	// for a given model and sink.
	RecordTimestamp time.Time
}

LastSentInfo holds the info about a "last sent" value.

type LastSentResult

type LastSentResult struct {
	LastSentInfo

	// Error holds the error, if any, that resulted while handling the
	// request for the ID.
	Error error
}

LastSentResult holds a single result from a bulk API call.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL