fake_doppler

Documentation

Index

• type FakeDoppler
  • func New() *FakeDoppler
  • func (fakeDoppler *FakeDoppler) CloseLogMessageStream()
  • func (fakeDoppler *FakeDoppler) ContainerMetrics(ctx context.Context, request *plumbing.ContainerMetricsRequest) (*plumbing.ContainerMetricsResponse, error)
  • func (fakeDoppler *FakeDoppler) RecentLogs(ctx context.Context, request *plumbing.RecentLogsRequest) (*plumbing.RecentLogsResponse, error)
  • func (fakeDoppler *FakeDoppler) SendLogMessage(messageBody []byte)
  • func (fakeDoppler *FakeDoppler) Start() error
  • func (fakeDoppler *FakeDoppler) Stop()
  • func (fakeDoppler *FakeDoppler) Subscribe(request *plumbing.SubscriptionRequest, server plumbing.Doppler_SubscribeServer) error

Types

type FakeDoppler

type FakeDoppler struct {
	GrpcEndpoint string

	SubscriptionRequests     chan *plumbing.SubscriptionRequest
	ContainerMetricsRequests chan *plumbing.ContainerMetricsRequest
	RecentLogsRequests       chan *plumbing.RecentLogsRequest
	SubscribeServers         chan plumbing.Doppler_SubscribeServer

	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New() *FakeDoppler

func (*FakeDoppler) CloseLogMessageStream

func (fakeDoppler *FakeDoppler) CloseLogMessageStream()

func (*FakeDoppler) ContainerMetrics

func (fakeDoppler *FakeDoppler) ContainerMetrics(ctx context.Context, request *plumbing.ContainerMetricsRequest) (*plumbing.ContainerMetricsResponse, error)

func (*FakeDoppler) RecentLogs

func (fakeDoppler *FakeDoppler) RecentLogs(ctx context.Context, request *plumbing.RecentLogsRequest) (*plumbing.RecentLogsResponse, error)

func (*FakeDoppler) SendLogMessage

func (fakeDoppler *FakeDoppler) SendLogMessage(messageBody []byte)

func (*FakeDoppler) Start

func (fakeDoppler *FakeDoppler) Start() error

func (*FakeDoppler) Stop

func (fakeDoppler *FakeDoppler) Stop()

func (*FakeDoppler) Subscribe

func (fakeDoppler *FakeDoppler) Subscribe(request *plumbing.SubscriptionRequest, server plumbing.Doppler_SubscribeServer) error