123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148 |
- package jsoniter
- import (
- "bytes"
- "io"
- )
- type RawMessage []byte
- func Unmarshal(data []byte, v interface{}) error {
- return ConfigDefault.Unmarshal(data, v)
- }
- func UnmarshalFromString(str string, v interface{}) error {
- return ConfigDefault.UnmarshalFromString(str, v)
- }
- func Get(data []byte, path ...interface{}) Any {
- return ConfigDefault.Get(data, path...)
- }
- func Marshal(v interface{}) ([]byte, error) {
- return ConfigDefault.Marshal(v)
- }
- func MarshalIndent(v interface{}, prefix, indent string) ([]byte, error) {
- return ConfigDefault.MarshalIndent(v, prefix, indent)
- }
- func MarshalToString(v interface{}) (string, error) {
- return ConfigDefault.MarshalToString(v)
- }
- func NewDecoder(reader io.Reader) *Decoder {
- return ConfigDefault.NewDecoder(reader)
- }
- type Decoder struct {
- iter *Iterator
- }
- func (adapter *Decoder) Decode(obj interface{}) error {
- if adapter.iter.head == adapter.iter.tail && adapter.iter.reader != nil {
- if !adapter.iter.loadMore() {
- return io.EOF
- }
- }
- adapter.iter.ReadVal(obj)
- err := adapter.iter.Error
- if err == io.EOF {
- return nil
- }
- return adapter.iter.Error
- }
- func (adapter *Decoder) More() bool {
- iter := adapter.iter
- if iter.Error != nil {
- return false
- }
- if iter.head != iter.tail {
- return true
- }
- return iter.loadMore()
- }
- func (adapter *Decoder) Buffered() io.Reader {
- remaining := adapter.iter.buf[adapter.iter.head:adapter.iter.tail]
- return bytes.NewReader(remaining)
- }
- func (adapter *Decoder) UseNumber() {
- cfg := adapter.iter.cfg.configBeforeFrozen
- cfg.UseNumber = true
- adapter.iter.cfg = cfg.frozeWithCacheReuse()
- }
- func (adapter *Decoder) DisallowUnknownFields() {
- cfg := adapter.iter.cfg.configBeforeFrozen
- cfg.DisallowUnknownFields = true
- adapter.iter.cfg = cfg.frozeWithCacheReuse()
- }
- func NewEncoder(writer io.Writer) *Encoder {
- return ConfigDefault.NewEncoder(writer)
- }
- type Encoder struct {
- stream *Stream
- }
- func (adapter *Encoder) Encode(val interface{}) error {
- adapter.stream.WriteVal(val)
- adapter.stream.WriteRaw("\n")
- adapter.stream.Flush()
- return adapter.stream.Error
- }
- func (adapter *Encoder) SetIndent(prefix, indent string) {
- config := adapter.stream.cfg.configBeforeFrozen
- config.IndentionStep = len(indent)
- adapter.stream.cfg = config.frozeWithCacheReuse()
- }
- func (adapter *Encoder) SetEscapeHTML(escapeHTML bool) {
- config := adapter.stream.cfg.configBeforeFrozen
- config.EscapeHTML = escapeHTML
- adapter.stream.cfg = config.frozeWithCacheReuse()
- }
- func Valid(data []byte) bool {
- return ConfigDefault.Valid(data)
- }
|