xconsumer

Documentation

Index

• type ConsumeProfilesFunc
  • func (f ConsumeProfilesFunc) ConsumeProfiles(ctx context.Context, td pprofile.Profiles) error
• type Profiles
  • func NewProfiles(consume ConsumeProfilesFunc, options ...consumer.Option) (Profiles, error)

Types

type ConsumeProfilesFunc

type ConsumeProfilesFunc func(ctx context.Context, td pprofile.Profiles) error

ConsumeProfilesFunc is a helper function that is similar to ConsumeProfiles.

func (ConsumeProfilesFunc) ConsumeProfiles

func (f ConsumeProfilesFunc) ConsumeProfiles(ctx context.Context, td pprofile.Profiles) error

ConsumeProfiles calls f(ctx, td).

type Profiles

type Profiles interface {
	internal.BaseConsumer
	// ConsumeProfiles receives pprofile.Profiles for consumption.
	ConsumeProfiles(ctx context.Context, td pprofile.Profiles) error
}

Profiles is an interface that receives pprofile.Profiles, processes it as needed, and sends it to the next processing node if any or to the destination.

func NewProfiles

func NewProfiles(consume ConsumeProfilesFunc, options ...consumer.Option) (Profiles, error)

NewProfiles returns a Profiles configured with the provided options.