mirror of
https://github.com/hanzoai/traces.git
synced 2026-10-30 18:20:41 +00:00
* added files to handle dualstack mode for minio s3 handler * added changes on api.go * Update tempodb/backend/s3/s3.go Co-authored-by: Mario <[email protected]> * Update tempodb/backend/s3/config.go Co-authored-by: Mario <[email protected]> * Update docs/sources/tempo/configuration/manifest.md Co-authored-by: Mario <[email protected]> * Update docs/sources/tempo/setup/linux.md Co-authored-by: Mario <[email protected]> * Update docs/sources/tempo/configuration/manifest.md Co-authored-by: Mario <[email protected]> * Update docs/sources/tempo/configuration/_index.md Co-authored-by: Mario <[email protected]> * added docs for dualstack * final commit * initiate client object * Fix IAM test * Added changelog entry * Update docs/sources/tempo/configuration/_index.md --------- Co-authored-by: Mario <[email protected]> Co-authored-by: Kim Nylander <[email protected]>
84 lines
1.8 KiB
Go
84 lines
1.8 KiB
Go
package decoder
|
|
|
|
import (
|
|
"fmt"
|
|
"unsafe"
|
|
|
|
"github.com/goccy/go-json/internal/errors"
|
|
)
|
|
|
|
type boolDecoder struct {
|
|
structName string
|
|
fieldName string
|
|
}
|
|
|
|
func newBoolDecoder(structName, fieldName string) *boolDecoder {
|
|
return &boolDecoder{structName: structName, fieldName: fieldName}
|
|
}
|
|
|
|
func (d *boolDecoder) DecodeStream(s *Stream, depth int64, p unsafe.Pointer) error {
|
|
c := s.skipWhiteSpace()
|
|
for {
|
|
switch c {
|
|
case 't':
|
|
if err := trueBytes(s); err != nil {
|
|
return err
|
|
}
|
|
**(**bool)(unsafe.Pointer(&p)) = true
|
|
return nil
|
|
case 'f':
|
|
if err := falseBytes(s); err != nil {
|
|
return err
|
|
}
|
|
**(**bool)(unsafe.Pointer(&p)) = false
|
|
return nil
|
|
case 'n':
|
|
if err := nullBytes(s); err != nil {
|
|
return err
|
|
}
|
|
return nil
|
|
case nul:
|
|
if s.read() {
|
|
c = s.char()
|
|
continue
|
|
}
|
|
goto ERROR
|
|
}
|
|
break
|
|
}
|
|
ERROR:
|
|
return errors.ErrUnexpectedEndOfJSON("bool", s.totalOffset())
|
|
}
|
|
|
|
func (d *boolDecoder) Decode(ctx *RuntimeContext, cursor, depth int64, p unsafe.Pointer) (int64, error) {
|
|
buf := ctx.Buf
|
|
cursor = skipWhiteSpace(buf, cursor)
|
|
switch buf[cursor] {
|
|
case 't':
|
|
if err := validateTrue(buf, cursor); err != nil {
|
|
return 0, err
|
|
}
|
|
cursor += 4
|
|
**(**bool)(unsafe.Pointer(&p)) = true
|
|
return cursor, nil
|
|
case 'f':
|
|
if err := validateFalse(buf, cursor); err != nil {
|
|
return 0, err
|
|
}
|
|
cursor += 5
|
|
**(**bool)(unsafe.Pointer(&p)) = false
|
|
return cursor, nil
|
|
case 'n':
|
|
if err := validateNull(buf, cursor); err != nil {
|
|
return 0, err
|
|
}
|
|
cursor += 4
|
|
return cursor, nil
|
|
}
|
|
return 0, errors.ErrUnexpectedEndOfJSON("bool", cursor)
|
|
}
|
|
|
|
func (d *boolDecoder) DecodePath(ctx *RuntimeContext, cursor, depth int64) ([][]byte, int64, error) {
|
|
return nil, 0, fmt.Errorf("json: bool decoder does not support decode path")
|
|
}
|