history

Documentation

Index

• Constants
• type FileScribe
  • func NewFileScribe(fileRoot string, saveInterval time.Duration) (*FileScribe, error)
  • func (s *FileScribe) Record(rec *Record, out *int) error
• type MockScribe
  • func NewMockScribe() (*MockScribe, error)
  • func (s *MockScribe) Record(rec *Record, out *int) error
• type ProxyScribe
  • func NewProxyScribe(addr, encoding string) (*ProxyScribe, error)
  • func (ps *ProxyScribe) Record(rec *Record, out *int) error
• type Record
• type Scribe

Constants

const (
	DESTINATIONS_FILE    = "destinations.json"
	RATING_PLANS_FILE    = "rating_plans.json"
	RATING_PROFILES_FILE = "rating_profiles.json"
)

const (
	JSON = "json"
	GOB  = "gob"
)

const (
	RATING_PLAN_PREFIX    = "rpl_"
	RATING_PROFILE_PREFIX = "rpf_"
	DESTINATION_PREFIX    = "dst_"
)

Types

type FileScribe

type FileScribe struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewFileScribe

func NewFileScribe(fileRoot string, saveInterval time.Duration) (*FileScribe, error)

func (*FileScribe) Record

func (s *FileScribe) Record(rec *Record, out *int) error

type MockScribe

type MockScribe struct {
	sync.Mutex

	DestBuf bytes.Buffer
	RplBuf  bytes.Buffer
	RpBuf   bytes.Buffer
	// contains filtered or unexported fields
}

func NewMockScribe

func NewMockScribe() (*MockScribe, error)

func (*MockScribe) Record

func (s *MockScribe) Record(rec *Record, out *int) error

type ProxyScribe

type ProxyScribe struct {
	Client *rpc.Client
}

func NewProxyScribe

func NewProxyScribe(addr, encoding string) (*ProxyScribe, error)

func (*ProxyScribe) Record

func (ps *ProxyScribe) Record(rec *Record, out *int) error

type Record

type Record struct {
	Key    string
	Object interface{}
}

type Scribe

type Scribe interface {
	Record(record *Record, out *int) error
}