logcollector

Documentation

Index

• func Run(ctx context.Context, optionValues ...Option)
• type Option
  • func WithAwsRegion(awsRegion string) Option
  • func WithDisableSSL(disableSSL bool) Option
  • func WithEndpoint(endpoint string) Option
  • func WithErrorListener(errListener util.ErrorListener) Option
  • func WithHTTPClient(httpClient *http.Client) Option
  • func WithS3ForcePathStyle(s3ForcePathStyle bool) Option
  • func WithS3UrlPrefix(s3UrlPrefix string) Option
  • func WithServer() Option
  • func WithSocketNameSuffix(socketNameSuffix string) Option
  • func WithTokener(value token.Accessor) Option

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)