Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var ( // ErrNoAccess is returned from methods to indicate that the requested // operation could not be performed because the user does not have access // to that data or function. ErrNoAccess = errors.New("coordinator: no access") // ErrNoSuchStream is returned when the requested strem path does not exist. ErrNoSuchStream = errors.New("coordinator: no such stream") )
var ( // Scopes is the set of scopes needed for the Coordinator user endpoints. Scopes = []string{ auth.OAuthScopeEmail, } )
Functions ¶
Types ¶
type Client ¶
type Client struct {
// C is the underlying LogsClient interface.
C logdog.LogsClient
// Host is the LogDog host. This is loaded from the pRPC client in NewClient.
Host string
}
Client wraps a Logs client with user-friendly methods.
Each method should operate independently, so calling methods from different goroutines must not cause any problems.
func NewClient ¶
NewClient returns a new Client instance bound to a pRPC Client.
func (*Client) Query ¶
func (c *Client) Query(ctx context.Context, project cfgtypes.ProjectName, path string, o QueryOptions, cb QueryCallback) error
Query executes a query, invoking the supplied callback once for each query result.
The path is the query parameter.
The path expression may substitute a glob ("*") for a specific path component. That is, any stream that matches the remaining structure qualifies regardless of its value in that specific positional field.
An unbounded wildcard may appear as a component at the end of both the prefix and name query components. "**" matches all remaining components.
If the supplied path query does not contain a path separator ("+"), it will be treated as if the prefix is "**".
Examples:
- Empty ("") will return all streams.
- **/+/** will return all streams.
- foo/bar/** will return all streams with the "foo/bar" prefix.
- foo/bar/**/+/baz will return all streams beginning with the "foo/bar" prefix and named "baz" (e.g., "foo/bar/qux/lol/+/baz")
- foo/bar/+/** will return all streams with a "foo/bar" prefix.
- foo/*/+/baz will return all streams with a two-component prefix whose first value is "foo" and whose name is "baz".
- foo/bar will return all streams whose name is "foo/bar".
- */* will return all streams with two-component names.
func (*Client) Stream ¶
func (c *Client) Stream(project cfgtypes.ProjectName, path types.StreamPath) *Stream
Stream returns a Stream instance for the named stream.
type GetParam ¶
type GetParam interface {
// contains filtered or unexported methods
}
GetParam is a condition or parameter to apply to a Get request.
func Index ¶
func Index(i types.MessageIndex) GetParam
Index returns a stream Get parameter that causes the Get request to retrieve logs starting at the requested stream index instead of the default, zero.
func LimitBytes ¶
LimitBytes applies a byte constraint to the returned logs. If the supplied limit is <= 0, then no byte constraint will be applied and the server will choose how many logs to return.
func LimitCount ¶
LimitCount applies a count constraint to the returned logs. If the supplied limit is <= 0, then no count constraint will be applied and the server will choose how many logs to return.
func NonContiguous ¶
func NonContiguous() GetParam
NonContiguous returns a stream Get parameter that causes the Get request to allow non-contiguous records to be returned. By default, only contiguous records starting from the specific Index will be returned.
By default, a log stream will return only contiguous records starting at the requested index. For example, if a stream had: {0, 1, 2, 4, 5} and a request was made for index 0, Get will return {0, 1, 2}, for index 3 {}, and for index 4 {4, 5}.
If NonContiguous is true, a request for 0 will return {0, 1, 2, 4, 5} and so on.
Log entries generally should not be missing, but may be if either the logs are still streaming (since they can be ingested out of order) or if a data loss or corruption occurs.
type LogStream ¶
type LogStream struct {
// Project is the log stream's project.
Project cfgtypes.ProjectName
// Path is the path of the log stream.
Path types.StreamPath
// Desc is the log stream's descriptor.
Desc logpb.LogStreamDescriptor
// State is the stream's current state.
State StreamState
}
LogStream is returned metadata about a log stream.
type QueryCallback ¶
QueryCallback is a callback method type that is used in query requests.
If it returns false, additional callbacks and queries will be aborted.
type QueryOptions ¶
type QueryOptions struct {
// Tags is the list of tags to require. The value may be empty if key presence
// is all that is being asserted.
Tags map[string]string
// ContentType, if not empty, restricts results to streams with the supplied
// content type.
ContentType string
// StreamType, if not STAny, is the stream type to query for.
StreamType QueryStreamType
// Before, if not zero, specifies that only streams registered at or before
// the supplied time should be returned.
Before time.Time
// After, if not zero, specifies that only streams registered at or after
// the supplied time should be returned.
After time.Time
// Purged, if not QBoth, selects logs streams that are/aren't purged.
Purged QueryTrinary
// State, if true, requests that the query results include the log streams'
// state.
State bool
}
QueryOptions is the set of query options that can accompany a query.
type QueryStreamType ¶
type QueryStreamType int
QueryStreamType is a 3-value query option type.
const ( // Any means that the value should not have an effect. Any QueryStreamType = iota // Text selects only text streams. Text // Binary selects only binary streams. Binary // Datagram selects only datagram streams. Datagram )
type QueryTrinary ¶
type QueryTrinary int
QueryTrinary is a 3-value query option type.
const ( // Both means that the value should not have an effect. Both QueryTrinary = iota // Yes is a positive effect. Yes // No is a negative effect. No )
type Stream ¶
type Stream struct {
// contains filtered or unexported fields
}
Stream is an interface to Coordinator stream-level commands. It is bound to and operates on a single log stream path.
func (*Stream) Get ¶
Get retrieves log stream entries from the Coordinator. The supplied parameters shape which entries are requested and what information is returned.
func (*Stream) State ¶
State fetches the LogStreamDescriptor for a given log stream.
type StreamState ¶
type StreamState struct {
// Created is the time, represented as a UTC RFC3339 string, when the log
// stream was created.
Created time.Time
// Updated is the time, represented as a UTC RFC3339 string, when the log
// stream was last updated.
Updated time.Time
// TerminalIndex is the stream index of the log stream's terminal message. If
// its value is <0, then the log stream has not terminated yet.
// In this case, FinishedIndex is the index of that terminal message.
TerminalIndex types.MessageIndex
// Archived is true if the stream is marked as archived.
Archived bool
// ArchiveIndexURL is the Google Storage URL where the log stream's index is
// archived.
ArchiveIndexURL string
// ArchiveStreamURL is the Google Storage URL where the log stream's raw
// stream data is archived. If this is not empty, the log stream is considered
// archived.
ArchiveStreamURL string
// ArchiveDataURL is the Google Storage URL where the log stream's assembled
// data is archived. If this is not empty, the log stream is considered
// archived.
ArchiveDataURL string
// Purged indicates the purged state of a log. A log that has been purged is
// only acknowledged to administrative clients.
Purged bool
}
StreamState represents the client-side state of the log stream.
It is a type-promoted version of logdog.LogStreamState.
type TailParam ¶
type TailParam interface {
// contains filtered or unexported methods
}
TailParam is a condition or parameter to apply to a Tail request.
func Complete ¶
func Complete() TailParam
Complete instructs the Tail call to retrieve a complete record.
If frgmented, the resulting record will be manufactured from its composite parts, and will not actually represent any single record in the log stream. The time offset, prefix and stream indices, sequence number, and content will be derived from the initial log entry in the composite set.
If the log stream is a TEXT or BINARY stream, no behavior change will occur, and the last log record will be returned.
If the log stream is a DATAGRAM stream and the Tail record is parked partial, additional log entries will be fetched via Get and the full log stream will be assembled. If the partial datagram entry is the "last" in its sequeence, the full datagram ending with it will be returned. If it's partial in the middle of a sequence, the previous complete datagram will be returned.
Source Files