functions

type Fn ¶

type Fn interface {
	ID() string
	Type() string
	Handle(ctx context.Context, msg *events.FunctionUpdated, storage database.Storage, msgCtx messaging.MsgContext, opts ...options.Option) error
}

func New() Fn

type Registry ¶

type Registry interface {
	Find(ctx context.Context, matchers ...RegistryMatcherFunc) ([]RegistryItem, error)
}

func NewRegistry(ctx context.Context, input io.Reader) (Registry, error)

type RegistryItem ¶

type RegistryItem struct {
	FnID    string
	Type    string
	Fn      Fn
	Options []options.Option
}

type RegistryMatcherFunc ¶

type RegistryMatcherFunc func(r *registry) []RegistryItem

func FindByFunctionID(functionId string) RegistryMatcherFunc

type RegistryMock ¶

type RegistryMock struct {
	// FindFunc mocks the Find method.
	FindFunc func(ctx context.Context, matchers ...RegistryMatcherFunc) ([]RegistryItem, error)
	// contains filtered or unexported fields
}

RegistryMock is a mock implementation of Registry.

func TestSomethingThatUsesRegistry(t *testing.T) {

	// make and configure a mocked Registry
	mockedRegistry := &RegistryMock{
		FindFunc: func(ctx context.Context, matchers ...RegistryMatcherFunc) ([]RegistryItem, error) {
			panic("mock out the Find method")
		},
	}

	// use mockedRegistry in code that requires Registry
	// and then make assertions.

}

func (mock *RegistryMock) Find(ctx context.Context, matchers ...RegistryMatcherFunc) ([]RegistryItem, error)

func (mock *RegistryMock) FindCalls() []struct {
	Ctx      context.Context
	Matchers []RegistryMatcherFunc
}

len(mockedRegistry.FindCalls())