thriftext

Documentation

Index

• type Adapter
  • func (t *Adapter) OnDataChange(newVal interface{}, src string) (err error)
• type DataChangeNotifier
• type DataListener
• type GetBytes
• type MultiNotifier
  • func NewMultiNotifier() *MultiNotifier
  • func (p *MultiNotifier) AddClient(notifier DataChangeNotifier)
  • func (p *MultiNotifier) OnChange(src string)
• type NoOp
  • func (t *NoOp) OnChange(path string)
  • func (t *NoOp) OnDataChange(newVal interface{}, path string) error
• type SetBytes
• type ThreadCtx
  • func NewThreadCtx() *ThreadCtx
  • func (p *ThreadCtx) ReadThrift(get GetBytes, emptyStruct thrift.TStruct) error
  • func (p *ThreadCtx) ReadThriftBytes(data []byte, emptyStruct thrift.TStruct) error
  • func (p *ThreadCtx) SetThrift(set SetBytes, tStruct thrift.TStruct) (path string, err error)
  • func (p *ThreadCtx) ToBytes(tStruct thrift.TStruct) ([]byte, error)

Types

type Adapter

type Adapter struct {
	Notifier DataChangeNotifier
}

func (*Adapter) OnDataChange

func (t *Adapter) OnDataChange(newVal interface{}, src string) (err error)

type DataChangeNotifier

type DataChangeNotifier interface {
	OnChange(str string)
}

type DataListener

type DataListener interface {
	OnDataChange(newVal interface{}, src string) (err error)
}

type GetBytes

type GetBytes func() ([]byte, error)

type MultiNotifier

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

func NewMultiNotifier

func NewMultiNotifier() *MultiNotifier

func (*MultiNotifier) AddClient

func (p *MultiNotifier) AddClient(notifier DataChangeNotifier)

func (*MultiNotifier) OnChange

func (p *MultiNotifier) OnChange(src string)

type NoOp

type NoOp struct{}

func (*NoOp) OnChange

func (t *NoOp) OnChange(path string)

func (*NoOp) OnDataChange

func (t *NoOp) OnDataChange(newVal interface{}, path string) error

type SetBytes

type SetBytes func(value []byte) (path string, err error)

type ThreadCtx

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

func NewThreadCtx

func NewThreadCtx() *ThreadCtx

func (*ThreadCtx) ReadThrift

func (p *ThreadCtx) ReadThrift(get GetBytes, emptyStruct thrift.TStruct) error

func (*ThreadCtx) ReadThriftBytes

func (p *ThreadCtx) ReadThriftBytes(data []byte, emptyStruct thrift.TStruct) error

func (*ThreadCtx) SetThrift

func (p *ThreadCtx) SetThrift(set SetBytes, tStruct thrift.TStruct) (path string, err error)

func (*ThreadCtx) ToBytes

func (p *ThreadCtx) ToBytes(tStruct thrift.TStruct) ([]byte, error)