command

package
v0.5.0 Latest Latest
Warning

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

Go to latest
Published: Sep 9, 2019 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func StreamLogs

func StreamLogs(logStreamUrl string, client doer, ap appProvider, writer io.Writer, options ...ApplyOptionFn)

Types

type ApplyOptionFn added in v0.4.0

type ApplyOptionFn func(*streamLogsOptions)

func WithMetricTypes added in v0.3.0

func WithMetricTypes(metricTypes []string) ApplyOptionFn

func WithShardID added in v0.4.0

func WithShardID(shardID string) ApplyOptionFn

func WithSourceIDs added in v0.3.0

func WithSourceIDs(sourceIDs []string) ApplyOptionFn

type AuthClient added in v0.4.0

type AuthClient struct {
	Client *http.Client
	// contains filtered or unexported fields
}

func NewAuthClient added in v0.4.0

func NewAuthClient(accessToken string, insecureSkipVerify bool) *AuthClient

func (*AuthClient) Do added in v0.4.0

func (d *AuthClient) Do(req *http.Request) (*http.Response, error)

type DedupeWriter added in v0.4.0

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

func NewDedupeWriter added in v0.4.0

func NewDedupeWriter(writer io.Writer) *DedupeWriter

func (*DedupeWriter) Write added in v0.4.0

func (s *DedupeWriter) Write(p []byte) (n int, err error)

Jump to

Keyboard shortcuts

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