logfwd

Documentation

Index

• type LastSentTracker
• type LogForwardingAPI
  • func NewLogForwardingAPI(st LogForwardingState, auth facade.Authorizer) (*LogForwardingAPI, error)
  • func (api *LogForwardingAPI) GetLastSent(args params.LogForwardingGetLastSentParams) params.LogForwardingGetLastSentResults
  • func (api *LogForwardingAPI) SetLastSent(args params.LogForwardingSetLastSentParams) params.ErrorResults
• type LogForwardingState

Types

type LastSentTracker

type LastSentTracker interface {
	io.Closer

	// Get retrieves the record ID and timestamp.
	Get() (recID int64, recTimestamp int64, err error)

	// Set records the record ID and timestamp.
	Set(recID int64, recTimestamp int64) error
}

LastSentTracker exposes the functionality of state.LastSentTracker.

type LogForwardingAPI

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

LogForwardingAPI is the concrete implementation of the api end point.

func NewLogForwardingAPI

func NewLogForwardingAPI(st LogForwardingState, auth facade.Authorizer) (*LogForwardingAPI, error)

NewLogForwardingAPI creates a new server-side logger API end point.

func (*LogForwardingAPI) GetLastSent

func (api *LogForwardingAPI) GetLastSent(args params.LogForwardingGetLastSentParams) params.LogForwardingGetLastSentResults

GetLastSent is a bulk call that gets the log forwarding "last sent" record ID for each requested target.

func (*LogForwardingAPI) SetLastSent

func (api *LogForwardingAPI) SetLastSent(args params.LogForwardingSetLastSentParams) params.ErrorResults

SetLastSent is a bulk call that sets the log forwarding "last sent" record ID for each requested target.

type LogForwardingState

type LogForwardingState interface {
	// NewLastSentTracker creates a new tracker for the given model
	// and log sink.
	NewLastSentTracker(tag names.ModelTag, sink string) LastSentTracker
}

LogForwardingState supports interacting with state for the LogForwarding facade.