otelbench

Documentation

Index

• func EnvSecuritySource() otelbotapi.SecuritySource
• func NewError(ctx context.Context, err Error) *otelbotapi.ErrorStatusCode
• type Error
• type Handler
  • func NewHandler(db *ent.Client, m *app.Metrics) *Handler
  • func (h Handler) GetStatus(ctx context.Context) (*otelbotapi.GetStatusOK, error)
  • func (h Handler) HandleTokenAuth(ctx context.Context, _ string, t otelbotapi.TokenAuth) (context.Context, error)
  • func (h Handler) NewError(ctx context.Context, err error) *otelbotapi.ErrorStatusCode
  • func (h Handler) Ping(ctx context.Context) error
• type Reader
  • func NewReader(r io.Reader) *Reader
  • func (r *Reader) Data() []byte
  • func (r *Reader) Decode() bool
  • func (r *Reader) Err() error
• type Writer
  • func NewWriter(w io.Writer) *Writer
  • func (w *Writer) Encode(data []byte) error

Functions

func EnvSecuritySource

func EnvSecuritySource() otelbotapi.SecuritySource

func NewError

func NewError(ctx context.Context, err Error) *otelbotapi.ErrorStatusCode

NewError creates new structured error response. All fields are optional.

Types

type Error

type Error struct {
	StatusCode int
	Message    string
}

type Handler

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

Handler handles otelbench api.

func NewHandler

func NewHandler(db *ent.Client, m *app.Metrics) *Handler

NewHandler initializes and returns a new Handler.

func (Handler) GetStatus

func (h Handler) GetStatus(ctx context.Context) (*otelbotapi.GetStatusOK, error)

func (Handler) HandleTokenAuth

func (h Handler) HandleTokenAuth(ctx context.Context, _ string, t otelbotapi.TokenAuth) (context.Context, error)

func (Handler) NewError

func (h Handler) NewError(ctx context.Context, err error) *otelbotapi.ErrorStatusCode

func (Handler) Ping

func (h Handler) Ping(ctx context.Context) error

type Reader

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

Reader reads data from an io.Reader and decodes it as "rwq" protocol.

func NewReader

func NewReader(r io.Reader) *Reader

func (*Reader) Data

func (r *Reader) Data() []byte

func (*Reader) Decode

func (r *Reader) Decode() bool

func (*Reader) Err

func (r *Reader) Err() error

type Writer

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

Writer writes data to an io.Writer as "rwq" protocol.

func NewWriter

func NewWriter(w io.Writer) *Writer

func (*Writer) Encode

func (w *Writer) Encode(data []byte) error