logcollector

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Jan 1, 2021 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Run

func Run(ctx context.Context, optionValues ...Option)

Run starts the log collector service

Types

type Option

type Option func(o *options)

Option defines an option that can be set on the server

func WithAwsRegion

func WithAwsRegion(awsRegion string) Option

WithAwsRegion specifies the AWS region

func WithDisableSSL

func WithDisableSSL(disableSSL bool) Option

WithDisableSSL sets whether SSL is used to access the cloud

func WithEndpoint

func WithEndpoint(endpoint string) Option

WithEndpoint specifies the S3 endpoint

func WithErrorListener

func WithErrorListener(errListener util.ErrorListener) Option

WithErrorListener reports errors to the specified error listener

func WithHTTPClient

func WithHTTPClient(httpClient *http.Client) Option

WithHTTPClient specifies the HTTP client to use

func WithS3ForcePathStyle

func WithS3ForcePathStyle(s3ForcePathStyle bool) Option

WithS3ForcePathStyle sets whether path style needs to be forced

func WithS3UrlPrefix

func WithS3UrlPrefix(s3UrlPrefix string) Option

WithS3UrlPrefix specifies the S3 bucket and key prefix in the cloud E.g. s3://anki-device-logs-dev/victor

func WithServer

func WithServer() Option

WithServer specifies that an IPC server should be started so other processes can use log collection

func WithSocketNameSuffix

func WithSocketNameSuffix(socketNameSuffix string) Option

WithSocketNameSuffix specifies the (optional) suffix of the socket name

func WithTokener

func WithTokener(value token.Accessor) Option

WithTokener specifies that the given token.Accessor should be used to obtain authorization credentials (used to retrieve USerID)

Jump to

Keyboard shortcuts

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