Documentation ¶
Index ¶
- type FakeFirehose
- func (f *FakeFirehose) AddEvent(event events.Envelope)
- func (f *FakeFirehose) Close()
- func (f *FakeFirehose) CloseAliveConnection()
- func (f *FakeFirehose) KeepConnectionAlive()
- func (f *FakeFirehose) LastAuthorization() string
- func (f *FakeFirehose) Requested() bool
- func (f *FakeFirehose) ServeHTTP(rw http.ResponseWriter, r *http.Request)
- func (f *FakeFirehose) SetCloseMessage(message []byte)
- func (f *FakeFirehose) Start()
- func (f *FakeFirehose) URL() string
- type FakeIdleFirehose
- type FakeOpenTSDB
- type FakeTokenFetcher
- type FakeUAA
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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 events.Envelope)
func (*FakeFirehose) Close ¶
func (f *FakeFirehose) Close()
func (*FakeFirehose) CloseAliveConnection ¶
func (f *FakeFirehose) CloseAliveConnection()
func (*FakeFirehose) KeepConnectionAlive ¶
func (f *FakeFirehose) KeepConnectionAlive()
func (*FakeFirehose) LastAuthorization ¶
func (f *FakeFirehose) LastAuthorization() string
func (*FakeFirehose) Requested ¶
func (f *FakeFirehose) Requested() bool
func (*FakeFirehose) ServeHTTP ¶
func (f *FakeFirehose) ServeHTTP(rw http.ResponseWriter, r *http.Request)
func (*FakeFirehose) SetCloseMessage ¶
func (f *FakeFirehose) SetCloseMessage(message []byte)
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 FakeOpenTSDB ¶
type FakeOpenTSDB struct { ReceivedContents chan []byte // contains filtered or unexported fields }
func NewFakeOpenTSDB ¶
func NewFakeOpenTSDB() *FakeOpenTSDB
func (*FakeOpenTSDB) Close ¶
func (f *FakeOpenTSDB) Close()
func (*FakeOpenTSDB) ServeHTTP ¶
func (f *FakeOpenTSDB) ServeHTTP(rw http.ResponseWriter, r *http.Request)
func (*FakeOpenTSDB) Start ¶
func (f *FakeOpenTSDB) Start()
func (*FakeOpenTSDB) URL ¶
func (f *FakeOpenTSDB) URL() string
type FakeTokenFetcher ¶
type FakeTokenFetcher struct {
NumCalls int
}
func (*FakeTokenFetcher) FetchAuthToken ¶
func (tokenFetcher *FakeTokenFetcher) FetchAuthToken() string
Click to show internal directories.
Click to hide internal directories.