plugin

Documentation

Index

• type S3Plugin
  • func NewS3Plugin(logger hclog.Logger, s3Svc *s3.Client, s3Config config.S3, ...) (*S3Plugin, error)
  • func (h *S3Plugin) DependencyReader() dependencystore.Reader
  • func (h *S3Plugin) SpanReader() spanstore.Reader
  • func (h *S3Plugin) SpanWriter() spanstore.Writer

Types

type S3Plugin

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

func NewS3Plugin

func NewS3Plugin(logger hclog.Logger, s3Svc *s3.Client, s3Config config.S3, athenaSvc *athena.Client, athenaConfig config.Athena) (*S3Plugin, error)

func (*S3Plugin) DependencyReader

func (h *S3Plugin) DependencyReader() dependencystore.Reader

func (*S3Plugin) SpanReader

func (h *S3Plugin) SpanReader() spanstore.Reader

func (*S3Plugin) SpanWriter

func (h *S3Plugin) SpanWriter() spanstore.Writer