mock

package
v0.9.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 8, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CDCEvents = []etre.CDCEvent{
	etre.CDCEvent{EventId: "nru", EntityId: "e1", Rev: 0, Ts: 10},
	etre.CDCEvent{EventId: "vno", EntityId: "e2", Rev: 0, Ts: 13},
	etre.CDCEvent{EventId: "4pi", EntityId: "e3", Rev: 0, Ts: 13},
	etre.CDCEvent{EventId: "p34", EntityId: "e1", Rev: 1, Ts: 22},
	etre.CDCEvent{EventId: "vb0", EntityId: "e5", Rev: 0, Ts: 35},
	etre.CDCEvent{EventId: "bnu", EntityId: "e5", Rev: 1, Ts: 35},
	etre.CDCEvent{EventId: "qwp", EntityId: "e1", Rev: 3, Ts: 39},
	etre.CDCEvent{EventId: "61p", EntityId: "e1", Rev: 2, Ts: 42},
	etre.CDCEvent{EventId: "2oi", EntityId: "e2", Rev: 1, Ts: 44},
}

Some test events that can be insterted into a db.

View Source 
var (
	ErrConnector = errors.New("error in connector")
)
View Source 
var (
	ErrPoller = errors.New("error in poller")
)

Functions

This section is empty.

Types

type AuthPlugin 

type AuthPlugin struct {
	AuthenticateFunc func(*http.Request) (auth.Caller, error)
	AuthorizeFunc    func(auth.Caller, auth.Action) error
}

func (AuthPlugin) Authenticate 

func (a AuthPlugin) Authenticate(req *http.Request) (auth.Caller, error)

func (AuthPlugin) Authorize 

func (a AuthPlugin) Authorize(c auth.Caller, ac auth.Action) error

type CDCStore 

type CDCStore struct {
	WriteFunc func(etre.CDCEvent) error
	ReadFunc  func(cdc.Filter) ([]etre.CDCEvent, error)
}

func (*CDCStore) Read 

func (s *CDCStore) Read(filter cdc.Filter) ([]etre.CDCEvent, error)

func (*CDCStore) Write 

func (s *CDCStore) Write(e etre.CDCEvent) error

type Connector 

type Connector struct {
	ConnectFunc func() (*mgo.Session, error)
	CloseFunc   func()
}

func (*Connector) Close 

func (c *Connector) Close()

func (*Connector) Connect 

func (c *Connector) Connect() (*mgo.Session, error)

type Delayer 

type Delayer struct {
	MaxTimestampFunc func() (int64, error)
	BeginChangeFunc  func(string) error
	EndChangeFunc    func(string) error
}

func (*Delayer) BeginChange 

func (d *Delayer) BeginChange(changeId string) error

func (*Delayer) EndChange 

func (d *Delayer) EndChange(changeId string) error

func (*Delayer) MaxTimestamp 

func (d *Delayer) MaxTimestamp() (int64, error)

type EntityStore 

type EntityStore struct {
	ReadEntitiesFunc      func(string, query.Query, etre.QueryFilter) ([]etre.Entity, error)
	DeleteEntityLabelFunc func(entity.WriteOp, string) (etre.Entity, error)
	CreateEntitiesFunc    func(entity.WriteOp, []etre.Entity) ([]string, error)
	UpdateEntitiesFunc    func(entity.WriteOp, query.Query, etre.Entity) ([]etre.Entity, error)
	DeleteEntitiesFunc    func(entity.WriteOp, query.Query) ([]etre.Entity, error)
	DeleteLabelFunc       func(entity.WriteOp, string) (etre.Entity, error)
}

func (*EntityStore) CreateEntities 

func (s *EntityStore) CreateEntities(wo entity.WriteOp, entities []etre.Entity) ([]string, error)

func (*EntityStore) DeleteEntities 

func (s *EntityStore) DeleteEntities(wo entity.WriteOp, q query.Query) ([]etre.Entity, error)

func (*EntityStore) DeleteEntityLabel 

func (s *EntityStore) DeleteEntityLabel(wo entity.WriteOp, label string) (etre.Entity, error)

func (*EntityStore) DeleteLabel 

func (s *EntityStore) DeleteLabel(wo entity.WriteOp, label string) (etre.Entity, error)

func (*EntityStore) ReadEntities 

func (s *EntityStore) ReadEntities(entityType string, q query.Query, f etre.QueryFilter) ([]etre.Entity, error)

func (*EntityStore) UpdateEntities 

func (s *EntityStore) UpdateEntities(wo entity.WriteOp, q query.Query, u etre.Entity) ([]etre.Entity, error)

type Feed 

type Feed struct {
	StartFunc func()
	WaitFunc  func()
	StopFunc  func()
}

func (*Feed) Start 

func (f *Feed) Start()

func (*Feed) Stop 

func (f *Feed) Stop()

func (*Feed) Wait 

func (f *Feed) Wait()

type FeedFactory 

type FeedFactory struct {
	MakeWebsocketFunc func(*websocket.Conn) *cdc.WebsocketFeed
	MakeInternalFunc  func(int) *cdc.InternalFeed
}

func (*FeedFactory) MakeInternal 

func (ff *FeedFactory) MakeInternal(clientBufferSize int) *cdc.InternalFeed

func (*FeedFactory) MakeWebsocket 

func (ff *FeedFactory) MakeWebsocket(wsConn *websocket.Conn) *cdc.WebsocketFeed

type MetricMethodArgs 

type MetricMethodArgs struct {
	Method    string
	Metric    byte
	IntVal    int64
	StringVal string
}

type MetricRecorder 

type MetricRecorder struct {
	Called []MetricMethodArgs
}

MetricRecorder records the called methods and values.

func NewMetricsRecorder 

func NewMetricsRecorder() *MetricRecorder

func (*MetricRecorder) EntityType 

func (m *MetricRecorder) EntityType(et string)

func (*MetricRecorder) Inc 

func (m *MetricRecorder) Inc(mn byte, n int64)

func (*MetricRecorder) IncError 

func (m *MetricRecorder) IncError(mn byte)

func (*MetricRecorder) IncLabel 

func (m *MetricRecorder) IncLabel(mn byte, label string)

func (*MetricRecorder) Report 

func (m *MetricRecorder) Report(reset bool) etre.MetricsReport

func (*MetricRecorder) Reset 

func (m *MetricRecorder) Reset()

func (*MetricRecorder) Trace 

func (m *MetricRecorder) Trace(map[string]string)

func (*MetricRecorder) Val 

func (m *MetricRecorder) Val(mn byte, n int64)

type MetricsFactory 

type MetricsFactory struct {
	MetricRecorder *MetricRecorder
}

func (MetricsFactory) Make 

func (f MetricsFactory) Make(groupNames []string) metrics.Metrics

type Poller 

type Poller struct {
	RunFunc        func() error
	RegisterFunc   func(string) (<-chan etre.CDCEvent, int64, error)
	DeregisterFunc func(string)
	ErrorFunc      func() error
}

func (*Poller) Deregister 

func (p *Poller) Deregister(uuid string)

func (*Poller) Error 

func (p *Poller) Error() error

func (*Poller) Register 

func (p *Poller) Register(uuid string) (<-chan etre.CDCEvent, int64, error)

func (*Poller) Run 

func (p *Poller) Run() error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.