mock

package
v0.11.9 Latest Latest
Warning

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

 Go to latest Published: Jun 24, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Some test events that can be insterted into a db.

View Source 
var RawInsertEvents = []bson.M{
	primitive.M{
		"_id":         primitive.M{"_data": primitive.Binary{Data: []uint8{0x82, 0x5e, 0x8f, 0x5c, 0xf7, 0x0, 0x0, 0x0, 0x26, 0x46, 0x3c, 0x5f, 0x69, 0x64, 0x0, 0x3c, 0x61, 0x62, 0x63, 0x0, 0x0, 0x5a, 0x10, 0x4, 0x4d, 0x5e, 0xa3, 0x2c, 0x5c, 0x27, 0x4c, 0xf8, 0xb1, 0xad, 0x80, 0x30, 0x3a, 0x44, 0xbc, 0x82, 0x4}}},
		"documentKey": primitive.M{"_id": "abc"},
		"fullDocument": primitive.M{
			"_id":        "abc",
			"entityId":   "e13",
			"entityType": "node",
			"op":         "i",
			"rev":        int64(7),
			"ts":         54,
			"user":       "mike",
			"new":        primitive.M{"_id": "e13", "_rev": int64(7), "_type": "node", "foo": "bar"},
		},
		"ns":            primitive.M{"coll": "cdc", "db": "etre_test"},
		"operationType": "insert",
	},
}

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(context.Context, 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(ctx context.Context, e etre.CDCEvent) error

type ChangeStreamServer added in v0.11.0 

type ChangeStreamServer struct {
	WatchFunc func(string) (<-chan etre.CDCEvent, error)
	CloseFunc func(string)
	RunFunc   func() error
	StopFunc  func()
}

func (ChangeStreamServer) Close added in v0.11.0 

func (s ChangeStreamServer) Close(clientId string)

func (ChangeStreamServer) Run added in v0.11.0 

func (s ChangeStreamServer) Run() error

func (ChangeStreamServer) Stop added in v0.11.0 

func (s ChangeStreamServer) Stop()

func (ChangeStreamServer) Watch added in v0.11.0 

func (s ChangeStreamServer) Watch(clientId string) (<-chan etre.CDCEvent, error)

type EntityStore 

type EntityStore struct {
	WithContextFunc       func(context.Context) entity.Store
	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)

func (EntityStore) WithContext added in v0.11.0 

func (s EntityStore) WithContext(ctx context.Context) entity.Store

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) IncLabel 

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

func (*MetricRecorder) Report 

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

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 MetricsStore added in v0.9.2 

type MetricsStore struct {
	AddFunc   func(m metrics.Metrics, name string) error
	GetFunc   func(name string) metrics.Metrics
	NamesFunc func() []string
}

func (MetricsStore) Add added in v0.9.2 

func (s MetricsStore) Add(m metrics.Metrics, name string) error

func (MetricsStore) Get added in v0.9.2 

func (s MetricsStore) Get(name string) metrics.Metrics

func (MetricsStore) Names added in v0.9.2 

func (s MetricsStore) Names() []string

type Stream added in v0.11.0 

type Stream struct {
	StartFunc  func(sinceTs int64) <-chan etre.CDCEvent
	InSyncFunc func() chan struct{}
	StatusFunc func() changestream.Status
	StopFunc   func()
	ErrorFunc  func() error
}

func (Stream) Error added in v0.11.0 

func (s Stream) Error() error

func (Stream) InSync added in v0.11.0 

func (s Stream) InSync() chan struct{}

func (Stream) Start added in v0.11.0 

func (s Stream) Start(sinceTs int64) <-chan etre.CDCEvent

func (Stream) Status added in v0.11.0 

func (s Stream) Status() changestream.Status

func (Stream) Stop added in v0.11.0 

func (s Stream) Stop()

type StreamerFactory added in v0.11.0 

type StreamerFactory struct {
	MakeFunc func(clientId string) changestream.Streamer
}

func (StreamerFactory) Make added in v0.11.0 

func (f StreamerFactory) Make(clientId string) changestream.Streamer

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.