testhelpers

Documentation

Index

• func ProtoDimensionsToMap(dims []*sfxproto.Dimension) (m map[string]string)
• func ProtoPropertiesToMap(props []*sfxproto.Property) (m map[string]string)
• type FakeBosh
  • func NewFakeBosh() *FakeBosh
  • func (f *FakeBosh) AddVM(deploymentName string, id string, ip string)
  • func (f *FakeBosh) Close()
  • func (f *FakeBosh) ServeHTTP(rw http.ResponseWriter, r *http.Request)
  • func (f *FakeBosh) Start()
  • func (f *FakeBosh) URL() string
• type FakeCloudController
  • func NewFakeCloudController() *FakeCloudController
  • func (f *FakeCloudController) Close()
  • func (f *FakeCloudController) ServeHTTP(rw http.ResponseWriter, r *http.Request)
  • func (f *FakeCloudController) Start()
  • func (f *FakeCloudController) URL() string
• type FakeFirehose
  • func NewFakeFirehose() *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
  • 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 FakeSignalFx
  • func NewFakeSignalFx() *FakeSignalFx
  • func (f *FakeSignalFx) Close()
  • func (f *FakeSignalFx) EnsureNoDatapoints()
  • func (f *FakeSignalFx) GetIngestedDatapoints() []*sfxproto.DataPoint
  • func (f *FakeSignalFx) ServeHTTP(rw http.ResponseWriter, r *http.Request)
  • func (f *FakeSignalFx) Start()
  • func (f *FakeSignalFx) 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) SetAccessToken(accessToken string)
  • func (f *FakeUAA) Start()
  • func (f *FakeUAA) URL() string

Functions

func ProtoDimensionsToMap

func ProtoDimensionsToMap(dims []*sfxproto.Dimension) (m map[string]string)

func ProtoPropertiesToMap

func ProtoPropertiesToMap(props []*sfxproto.Property) (m map[string]string)

Types

type FakeBosh

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

func NewFakeBosh

func NewFakeBosh() *FakeBosh

func (*FakeBosh) AddVM

func (f *FakeBosh) AddVM(deploymentName string, id string, ip string)

func (*FakeBosh) Close

func (f *FakeBosh) Close()

func (*FakeBosh) ServeHTTP

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

Returns the app name as "app-<guid>" based on the guid passed in the path. This is meant to fake the `/v2/apps/<guid>` path, as well as the `/v2/info` path.

func (*FakeBosh) Start

func (f *FakeBosh) Start()

func (*FakeBosh) URL

func (f *FakeBosh) URL() string

type FakeCloudController

type FakeCloudController struct {
	AppReqCounts map[string]int
	// contains filtered or unexported fields
}

func NewFakeCloudController

func NewFakeCloudController() *FakeCloudController

func (*FakeCloudController) Close

func (f *FakeCloudController) Close()

func (*FakeCloudController) ServeHTTP

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

Returns the app name as "app-<guid>" based on the guid passed in the path. This is meant to fake the `/v2/apps/<guid>` path, as well as the `/v2/info` path.

func (*FakeCloudController) Start

func (f *FakeCloudController) Start()

func (*FakeCloudController) URL

func (f *FakeCloudController) URL() string

type FakeFirehose

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

func NewFakeFirehose

func NewFakeFirehose() *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 FakeSignalFx

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

func NewFakeSignalFx

func NewFakeSignalFx() *FakeSignalFx

func (*FakeSignalFx) Close

func (f *FakeSignalFx) Close()

func (*FakeSignalFx) EnsureNoDatapoints

func (f *FakeSignalFx) EnsureNoDatapoints()

func (*FakeSignalFx) GetIngestedDatapoints

func (f *FakeSignalFx) GetIngestedDatapoints() []*sfxproto.DataPoint

func (*FakeSignalFx) ServeHTTP

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

func (*FakeSignalFx) Start

func (f *FakeSignalFx) Start()

func (*FakeSignalFx) URL

func (f *FakeSignalFx) 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) SetAccessToken

func (f *FakeUAA) SetAccessToken(accessToken string)

func (*FakeUAA) Start

func (f *FakeUAA) Start()

func (*FakeUAA) URL

func (f *FakeUAA) URL() string