endpoints

Documentation

Index

• type DiskEndpoint
  • func NewDiskEndpoint(name string, path string, expiration time.Duration) *DiskEndpoint
  • func (ep *DiskEndpoint) BuildReport(r metrics.StampedMetricReport) (pipeline.EndpointReport, error)
  • func (ep *DiskEndpoint) IsTransient(err error) bool
  • func (ep *DiskEndpoint) Name() string
  • func (ep *DiskEndpoint) Release() error
  • func (ep *DiskEndpoint) Send(r pipeline.EndpointReport) error
  • func (ep *DiskEndpoint) Use()
• type ServiceControlEndpoint
  • func NewServiceControlEndpoint(name, serviceName, agentId string, consumerId string, jsonKey []byte) (*ServiceControlEndpoint, error)
  • func (ep *ServiceControlEndpoint) BuildReport(r metrics.StampedMetricReport) (pipeline.EndpointReport, error)
  • func (ep *ServiceControlEndpoint) IsTransient(err error) bool
  • func (ep *ServiceControlEndpoint) Name() string
  • func (ep *ServiceControlEndpoint) Release() error
  • func (ep *ServiceControlEndpoint) Send(report pipeline.EndpointReport) error
  • func (ep *ServiceControlEndpoint) Use()

Types

type DiskEndpoint

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

func NewDiskEndpoint

func NewDiskEndpoint(name string, path string, expiration time.Duration) *DiskEndpoint

NewDiskEndpoint creates a new DiskEndpoint and starts a goroutine that cleans up expired reports on disk.

func (*DiskEndpoint) BuildReport

func (ep *DiskEndpoint) BuildReport(r metrics.StampedMetricReport) (pipeline.EndpointReport, error)

func (*DiskEndpoint) IsTransient

func (ep *DiskEndpoint) IsTransient(err error) bool

func (*DiskEndpoint) Name

func (ep *DiskEndpoint) Name() string

func (*DiskEndpoint) Release

func (ep *DiskEndpoint) Release() error

Release decrements the DiskEndpoint's usage count. If it reaches 0, Release instructs the DiskEndpoint's cleanup goroutine to gracefully shutdown. It blocks until the operation has completed. See pipeline.Component.Release.

func (*DiskEndpoint) Send

func (ep *DiskEndpoint) Send(r pipeline.EndpointReport) error

func (*DiskEndpoint) Use

func (ep *DiskEndpoint) Use()

Use increments the DiskEndpoint's usage count. See pipeline.Component.Use.

type ServiceControlEndpoint

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

func NewServiceControlEndpoint

func NewServiceControlEndpoint(name, serviceName, agentId string, consumerId string, jsonKey []byte) (*ServiceControlEndpoint, error)

NewServiceControlEndpoint creates a new ServiceControlEndpoint.

func (*ServiceControlEndpoint) BuildReport

func (ep *ServiceControlEndpoint) BuildReport(r metrics.StampedMetricReport) (pipeline.EndpointReport, error)

func (*ServiceControlEndpoint) IsTransient

func (ep *ServiceControlEndpoint) IsTransient(err error) bool

func (*ServiceControlEndpoint) Name

func (ep *ServiceControlEndpoint) Name() string

func (*ServiceControlEndpoint) Release

func (ep *ServiceControlEndpoint) Release() error

Release is a no-op. ServiceControlEndpoint doesn't track usage.

func (*ServiceControlEndpoint) Send

func (ep *ServiceControlEndpoint) Send(report pipeline.EndpointReport) error

func (*ServiceControlEndpoint) Use

func (ep *ServiceControlEndpoint) Use()

Use is a no-op. ServiceControlEndpoint doesn't track usage.