ingress

Documentation

Index

• type LogClient
  • func NewLogClient(creds credentials.TransportCredentials, logsProviderAddr string) *LogClient
  • func (c *LogClient) Stream(ctx context.Context, req *loggregator_v2.EgressBatchRequest) web.Receiver

Types

type LogClient

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

LogClient handles dialing and opening streams to the logs provider.

func NewLogClient

func NewLogClient(creds credentials.TransportCredentials, logsProviderAddr string) *LogClient

NewClient dials the logs provider and returns a new log client.

func (*LogClient) Stream

func (c *LogClient) Stream(ctx context.Context, req *loggregator_v2.EgressBatchRequest) web.Receiver

Stream opens a new stream on the log client.