command

May 29, 2019

Changes in this version

+ type ApplyOptionFn func(*streamLogsOptions)

+ func WithShardID(shardID string) ApplyOptionFn

+ type AuthClient struct

+ Client *http.Client

+ func NewAuthClient(accessToken string, insecureSkipVerify bool) *AuthClient

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

+ type DedupeWriter struct

+ func NewDedupeWriter(writer io.Writer) *DedupeWriter

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

Feb 11, 2019

Changes in this version

+ func WithMetricTypes(metricTypes []string) applyOptionFn

+ func WithSourceIDs(sourceIDs []string) applyOptionFn

Feb 6, 2019

Changes in this version

+ func StreamLogs(sourceIDs []string, logStreamUrl string, doer log_stream_plugin.Doer, ...)