utils

Documentation

Index

• Constants
• func StringsContain(strs []string, str string) bool
• type DagReader
• type FileDagReader
  • func (r FileDagReader) ReadDag(path string) ([]byte, error)
  • func (r FileDagReader) ReadPathsFromDir(dir string) (dagFiles []string, err error)
• type KeyValueGetter
• type KeyValueIterateFunc
• type KeyValueIterator
• type MockDagReader
  • func (_m *MockDagReader) ReadDag(path string) ([]byte, error)
  • func (_m *MockDagReader) ReadPathsFromDir(dir string) ([]string, error)

Constants

const (
	LogKeyDagInsID = "dagInsId"
)

Functions

func StringsContain

func StringsContain(strs []string, str string) bool

StringsContain

Types

type DagReader

type DagReader interface {
	ReadPathsFromDir(dir string) ([]string, error)
	ReadDag(path string) ([]byte, error)
}

DagReader

var (
	DefaultReader DagReader = &FileDagReader{}
)

type FileDagReader

type FileDagReader struct {
}

FileDagReader

func (FileDagReader) ReadDag

func (r FileDagReader) ReadDag(path string) ([]byte, error)

ReadDag

func (FileDagReader) ReadPathsFromDir

func (r FileDagReader) ReadPathsFromDir(dir string) (dagFiles []string, err error)

ReadPathsFromDir

type KeyValueGetter

type KeyValueGetter func(key string) (string, bool)

type KeyValueIterateFunc

type KeyValueIterateFunc func(key, val string) (stop bool)

type KeyValueIterator

type KeyValueIterator func(KeyValueIterateFunc)

type MockDagReader

type MockDagReader struct {
	mock.Mock
}

MockDagReader is an autogenerated mock type for the DagReader type

func (*MockDagReader) ReadDag

func (_m *MockDagReader) ReadDag(path string) ([]byte, error)

ReadDag provides a mock function with given fields: path

func (*MockDagReader) ReadPathsFromDir

func (_m *MockDagReader) ReadPathsFromDir(dir string) ([]string, error)

ReadPathsFromDir provides a mock function with given fields: dir