cf

Documentation

Index

• type AppStreamProvider
• type Client
  • func NewClient(config *cfclient.Config, logCacheEndpoint string) (Client, error)
• type DopplerAppStreamProvider
  • func NewDopplerAppStreamProvider(client Client, appGUID string) *DopplerAppStreamProvider
  • func (d *DopplerAppStreamProvider) Close() error
  • func (d *DopplerAppStreamProvider) Start() (<-chan *sonde_events.Envelope, <-chan error)
• type LogCacheClient
• type ServiceInstance

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
}

func NewClient

func NewClient(config *cfclient.Config, logCacheEndpoint string) (Client, error)

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
}