Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AppStreamProvider ¶
type AppStreamProvider interface { Start() (<-chan *sonde_events.Envelope, <-chan error) Close() error }
type Client ¶
type Client interface { ListAppsWithSpaceAndOrg() ([]cfclient.App, error) ListServicesWithSpaceAndOrg() ([]ServiceInstance, error) NewAppStreamProvider(appGUID string) AppStreamProvider GetToken() (token string, authError error) consumer.TokenRefresher DopplerEndpoint() string NewLogCacheClient() LogCacheClient }
type DopplerAppStreamProvider ¶
type DopplerAppStreamProvider struct {
// contains filtered or unexported fields
}
func NewDopplerAppStreamProvider ¶
func NewDopplerAppStreamProvider(client Client, appGUID string) *DopplerAppStreamProvider
func (*DopplerAppStreamProvider) Close ¶
func (d *DopplerAppStreamProvider) Close() error
func (*DopplerAppStreamProvider) Start ¶
func (d *DopplerAppStreamProvider) Start() (<-chan *sonde_events.Envelope, <-chan error)
type LogCacheClient ¶
type LogCacheClient interface { Read( ctx context.Context, sourceID string, start time.Time, opts ...logcache.ReadOption, ) ([]*loggregator_v2.Envelope, error) }
type ServiceInstance ¶
type ServiceInstance struct { cfclient.ServiceInstance SpaceData cfclient.SpaceResource }
Click to show internal directories.
Click to hide internal directories.