helper

Documentation

Index

• Variables
• func Decompress(src []byte) []byte
• func Logger() *gosteno.Logger
• func StdOutLogger() *gosteno.Logger
• type FakeBufferSink
  • func NewFakeBufferSink(buffer *bytes.Buffer) *FakeBufferSink
  • func (x *FakeBufferSink) AddRecord(record *gosteno.Record)
  • func (x *FakeBufferSink) Flush()
  • func (x *FakeBufferSink) GetCodec() gosteno.Codec
  • func (x *FakeBufferSink) GetContent() string
  • func (x *FakeBufferSink) SetCodec(codec gosteno.Codec)
• type FakeCloudControllerAPI
  • func NewFakeCloudControllerAPI(tokenType string, accessToken string) *FakeCloudControllerAPI
  • func (f *FakeCloudControllerAPI) AuthToken() string
  • func (f *FakeCloudControllerAPI) Close()
  • func (f *FakeCloudControllerAPI) GetUsedEndpoints() []string
  • func (f *FakeCloudControllerAPI) ServeHTTP(rw http.ResponseWriter, r *http.Request)
  • func (f *FakeCloudControllerAPI) Start()
  • func (f *FakeCloudControllerAPI) URL() string
• type FakeClusterAgentAPI
  • func NewFakeClusterAgentAPI(tokenType string, accessToken string) *FakeClusterAgentAPI
  • func (f *FakeClusterAgentAPI) AuthToken() string
  • func (f *FakeClusterAgentAPI) Close()
  • func (f *FakeClusterAgentAPI) GetUsedEndpoints() []string
  • func (f *FakeClusterAgentAPI) ServeHTTP(rw http.ResponseWriter, r *http.Request)
  • func (f *FakeClusterAgentAPI) Start()
  • func (f *FakeClusterAgentAPI) URL() string
• type FakeDatadogAPI
  • func NewFakeDatadogAPI() *FakeDatadogAPI
  • func (f *FakeDatadogAPI) Close()
  • func (f *FakeDatadogAPI) ServeHTTP(rw http.ResponseWriter, r *http.Request)
  • func (f *FakeDatadogAPI) Start()
  • func (f *FakeDatadogAPI) URL() string
• type FakeFirehose
  • func NewFakeFirehose(validToken string) *FakeFirehose
  • func (f *FakeFirehose) AddEvent(event loggregator_v2.Envelope)
  • func (f *FakeFirehose) Close()
  • func (f *FakeFirehose) CloseServerLoop()
  • func (f *FakeFirehose) LastAuthorization() string
  • func (f *FakeFirehose) Requested() bool
  • func (f *FakeFirehose) ServeBatch()
  • func (f *FakeFirehose) ServeHTTP(rw http.ResponseWriter, r *http.Request)
  • func (f *FakeFirehose) SetToken(token string)
  • func (f *FakeFirehose) Start()
  • func (f *FakeFirehose) URL() string
• type FakeIdleFirehose
  • func NewFakeIdleFirehose(timeout time.Duration) *FakeIdleFirehose
  • func (f *FakeIdleFirehose) Close()
  • func (f *FakeIdleFirehose) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (f *FakeIdleFirehose) Start()
  • func (f *FakeIdleFirehose) URL() string
• type FakeTokenFetcher
  • func (tokenFetcher *FakeTokenFetcher) FetchAuthToken() string
• type FakeUAA
  • func NewFakeUAA(tokenType string, accessToken string) *FakeUAA
  • func (f *FakeUAA) AuthToken() string
  • func (f *FakeUAA) Close()
  • func (f *FakeUAA) Requested() bool
  • func (f *FakeUAA) ServeHTTP(rw http.ResponseWriter, r *http.Request)
  • func (f *FakeUAA) Start()
  • func (f *FakeUAA) TimesRequested() int
  • func (f *FakeUAA) URL() string
• type TestStenoSink
  • func (t *TestStenoSink) AddRecord(record *gosteno.Record)
  • func (t *TestStenoSink) Clear()
  • func (t *TestStenoSink) Flush()
  • func (t *TestStenoSink) GetCodec() gosteno.Codec
  • func (t *TestStenoSink) LogContents() string
  • func (t *TestStenoSink) SetCodec(codec gosteno.Codec)

Variables

var TestLoggerSink = new(TestStenoSink)

Functions

func Decompress

func Decompress(src []byte) []byte

func Logger

func Logger() *gosteno.Logger

func StdOutLogger

func StdOutLogger() *gosteno.Logger

Types

type FakeBufferSink

type FakeBufferSink struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewFakeBufferSink

func NewFakeBufferSink(buffer *bytes.Buffer) *FakeBufferSink

func (*FakeBufferSink) AddRecord

func (x *FakeBufferSink) AddRecord(record *gosteno.Record)

func (*FakeBufferSink) Flush

func (x *FakeBufferSink) Flush()

func (*FakeBufferSink) GetCodec

func (x *FakeBufferSink) GetCodec() gosteno.Codec

func (*FakeBufferSink) GetContent

func (x *FakeBufferSink) GetContent() string

func (*FakeBufferSink) SetCodec

func (x *FakeBufferSink) SetCodec(codec gosteno.Codec)

type FakeCloudControllerAPI

type FakeCloudControllerAPI struct {
	ReceivedContents chan []byte
	ReceivedRequests chan *http.Request

	// Used to make the controller slow to answer
	RequestTime time.Duration

	// Number of apps
	AppNumber int
	// contains filtered or unexported fields
}

FakeCloudControllerAPI mocks a cloud controller

func NewFakeCloudControllerAPI

func NewFakeCloudControllerAPI(tokenType string, accessToken string) *FakeCloudControllerAPI

NewFakeCloudControllerAPI create a new cloud controller

func (*FakeCloudControllerAPI) AuthToken

func (f *FakeCloudControllerAPI) AuthToken() string

AuthToken returns auth token

func (*FakeCloudControllerAPI) Close

func (f *FakeCloudControllerAPI) Close()

Close closes the cloud controller

func (*FakeCloudControllerAPI) GetUsedEndpoints

func (f *FakeCloudControllerAPI) GetUsedEndpoints() []string

func (*FakeCloudControllerAPI) ServeHTTP

func (f *FakeCloudControllerAPI) ServeHTTP(rw http.ResponseWriter, r *http.Request)

ServeHTTP listens for http requests

func (*FakeCloudControllerAPI) Start

func (f *FakeCloudControllerAPI) Start()

Start starts the cloud controller

func (*FakeCloudControllerAPI) URL

func (f *FakeCloudControllerAPI) URL() string

URL returns the API url

type FakeClusterAgentAPI

type FakeClusterAgentAPI struct {
	ReceivedContents chan []byte
	ReceivedRequests chan *http.Request

	// Used to make the controller slow to answer
	RequestTime time.Duration
	// contains filtered or unexported fields
}

FakeClusterAgentAPI mocks a cloud controller

func NewFakeClusterAgentAPI

func NewFakeClusterAgentAPI(tokenType string, accessToken string) *FakeClusterAgentAPI

NewFakeClusterAgentAPI create a new cloud controller

func (*FakeClusterAgentAPI) AuthToken

func (f *FakeClusterAgentAPI) AuthToken() string

AuthToken returns auth token

func (*FakeClusterAgentAPI) Close

func (f *FakeClusterAgentAPI) Close()

Close closes the cloud controller

func (*FakeClusterAgentAPI) GetUsedEndpoints

func (f *FakeClusterAgentAPI) GetUsedEndpoints() []string

func (*FakeClusterAgentAPI) ServeHTTP

func (f *FakeClusterAgentAPI) ServeHTTP(rw http.ResponseWriter, r *http.Request)

ServeHTTP listens for http requests

func (*FakeClusterAgentAPI) Start

func (f *FakeClusterAgentAPI) Start()

Start starts the cloud controller

func (*FakeClusterAgentAPI) URL

func (f *FakeClusterAgentAPI) URL() string

URL returns the API url

type FakeDatadogAPI

type FakeDatadogAPI struct {
	ReceivedContents chan []byte
	// contains filtered or unexported fields
}

func NewFakeDatadogAPI

func NewFakeDatadogAPI() *FakeDatadogAPI

func (*FakeDatadogAPI) Close

func (f *FakeDatadogAPI) Close()

func (*FakeDatadogAPI) ServeHTTP

func (f *FakeDatadogAPI) ServeHTTP(rw http.ResponseWriter, r *http.Request)

func (*FakeDatadogAPI) Start

func (f *FakeDatadogAPI) Start()

func (*FakeDatadogAPI) URL

func (f *FakeDatadogAPI) URL() string

type FakeFirehose

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

func NewFakeFirehose

func NewFakeFirehose(validToken string) *FakeFirehose

func (*FakeFirehose) AddEvent

func (f *FakeFirehose) AddEvent(event loggregator_v2.Envelope)

func (*FakeFirehose) Close

func (f *FakeFirehose) Close()

func (*FakeFirehose) CloseServerLoop

func (f *FakeFirehose) CloseServerLoop()

func (*FakeFirehose) LastAuthorization

func (f *FakeFirehose) LastAuthorization() string

func (*FakeFirehose) Requested

func (f *FakeFirehose) Requested() bool

func (*FakeFirehose) ServeBatch

func (f *FakeFirehose) ServeBatch()

func (*FakeFirehose) ServeHTTP

func (f *FakeFirehose) ServeHTTP(rw http.ResponseWriter, r *http.Request)

func (*FakeFirehose) SetToken

func (f *FakeFirehose) SetToken(token string)

func (*FakeFirehose) Start

func (f *FakeFirehose) Start()

func (*FakeFirehose) URL

func (f *FakeFirehose) URL() string

type FakeIdleFirehose

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

func NewFakeIdleFirehose

func NewFakeIdleFirehose(timeout time.Duration) *FakeIdleFirehose

func (*FakeIdleFirehose) Close

func (f *FakeIdleFirehose) Close()

func (*FakeIdleFirehose) ServeHTTP

func (f *FakeIdleFirehose) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*FakeIdleFirehose) Start

func (f *FakeIdleFirehose) Start()

func (*FakeIdleFirehose) URL

func (f *FakeIdleFirehose) URL() string

type FakeTokenFetcher

type FakeTokenFetcher struct {
	NumCalls int
}

func (*FakeTokenFetcher) FetchAuthToken

func (tokenFetcher *FakeTokenFetcher) FetchAuthToken() string

type FakeUAA

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

func NewFakeUAA

func NewFakeUAA(tokenType string, accessToken string) *FakeUAA

func (*FakeUAA) AuthToken

func (f *FakeUAA) AuthToken() string

func (*FakeUAA) Close

func (f *FakeUAA) Close()

func (*FakeUAA) Requested

func (f *FakeUAA) Requested() bool

func (*FakeUAA) ServeHTTP

func (f *FakeUAA) ServeHTTP(rw http.ResponseWriter, r *http.Request)

func (*FakeUAA) Start

func (f *FakeUAA) Start()

func (*FakeUAA) TimesRequested

func (f *FakeUAA) TimesRequested() int

func (*FakeUAA) URL

func (f *FakeUAA) URL() string

type TestStenoSink

type TestStenoSink struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*TestStenoSink) AddRecord

func (t *TestStenoSink) AddRecord(record *gosteno.Record)

func (*TestStenoSink) Clear

func (t *TestStenoSink) Clear()

func (*TestStenoSink) Flush

func (t *TestStenoSink) Flush()

func (*TestStenoSink) GetCodec

func (t *TestStenoSink) GetCodec() gosteno.Codec

func (*TestStenoSink) LogContents

func (t *TestStenoSink) LogContents() string

func (*TestStenoSink) SetCodec

func (t *TestStenoSink) SetCodec(codec gosteno.Codec)