filedatastore

Documentation

Index

• Constants
• type FileDatastore
  • func NewFileDatastore(srv *server.Server) *FileDatastore
  • func (fdmodule *FileDatastore) Init(cfg module.ModuleConfig) error
  • func (fdmodule *FileDatastore) IsRunning() bool
  • func (fdmodule *FileDatastore) PrerequisiteModules() []string
  • func (fdmodule *FileDatastore) Start() error
  • func (fdmodule *FileDatastore) Stop() error
• type FileDatastoreImpl
  • func NewFileDatastoreImpl(srv *server.Server) *FileDatastoreImpl
  • func (datastore *FileDatastoreImpl) AddJob(ctx context.Context, job *model.Job) error
  • func (datastore *FileDatastoreImpl) AddNode(ctx context.Context, node *model.Node) error
  • func (datastore *FileDatastoreImpl) AddPivotJob(ctx context.Context, job *model.Job) error
  • func (datastore *FileDatastoreImpl) CreateJob(ctx context.Context) *model.Job
  • func (datastore *FileDatastoreImpl) CreateNode(ctx context.Context, id string) *model.Node
  • func (datastore *FileDatastoreImpl) DeleteJob(ctx context.Context, jobId int) (*model.Job, error)
  • func (datastore *FileDatastoreImpl) GetJob(ctx context.Context, jobId int) *model.Job
  • func (datastore *FileDatastoreImpl) GetJobs(ctx context.Context, kind string, parameters map[string]interface{}) []*model.Job
  • func (datastore *FileDatastoreImpl) GetNextJob(ctx context.Context, nodeId string) *model.Job
  • func (datastore *FileDatastoreImpl) GetNodes(ctx context.Context) []*model.Node
  • func (datastore *FileDatastoreImpl) GetPacketStream(ctx context.Context, jobId int, unwrap bool) (io.ReadCloser, string, int64, error)
  • func (datastore *FileDatastoreImpl) GetPackets(ctx context.Context, jobId int, offset int, count int, unwrap bool) ([]*model.Packet, error)
  • func (datastore *FileDatastoreImpl) Init(cfg module.ModuleConfig) error
  • func (datastore *FileDatastoreImpl) SavePacketStream(ctx context.Context, jobId int, reader io.ReadCloser) error
  • func (datastore *FileDatastoreImpl) UpdateJob(ctx context.Context, job *model.Job) error
  • func (datastore *FileDatastoreImpl) UpdateNode(ctx context.Context, newNode *model.Node) (*model.Node, error)

Constants

const DEFAULT_RETRY_FAILURE_INTERVAL_MS = 600000

Types

type FileDatastore

type FileDatastore struct {
	// contains filtered or unexported fields
}

func NewFileDatastore

func NewFileDatastore(srv *server.Server) *FileDatastore

func (*FileDatastore) Init

func (fdmodule *FileDatastore) Init(cfg module.ModuleConfig) error

func (*FileDatastore) IsRunning

func (fdmodule *FileDatastore) IsRunning() bool

func (*FileDatastore) PrerequisiteModules

func (fdmodule *FileDatastore) PrerequisiteModules() []string

func (*FileDatastore) Start

func (fdmodule *FileDatastore) Start() error

func (*FileDatastore) Stop

func (fdmodule *FileDatastore) Stop() error

type FileDatastoreImpl

type FileDatastoreImpl struct {
	// contains filtered or unexported fields
}

func NewFileDatastoreImpl

func NewFileDatastoreImpl(srv *server.Server) *FileDatastoreImpl

func (*FileDatastoreImpl) AddJob

func (datastore *FileDatastoreImpl) AddJob(ctx context.Context, job *model.Job) error

func (*FileDatastoreImpl) AddNode

func (datastore *FileDatastoreImpl) AddNode(ctx context.Context, node *model.Node) error

func (*FileDatastoreImpl) AddPivotJob

func (datastore *FileDatastoreImpl) AddPivotJob(ctx context.Context, job *model.Job) error

func (*FileDatastoreImpl) CreateJob

func (datastore *FileDatastoreImpl) CreateJob(ctx context.Context) *model.Job

func (*FileDatastoreImpl) CreateNode

func (datastore *FileDatastoreImpl) CreateNode(ctx context.Context, id string) *model.Node

func (*FileDatastoreImpl) DeleteJob

func (datastore *FileDatastoreImpl) DeleteJob(ctx context.Context, jobId int) (*model.Job, error)

func (*FileDatastoreImpl) GetJob

func (datastore *FileDatastoreImpl) GetJob(ctx context.Context, jobId int) *model.Job

func (*FileDatastoreImpl) GetJobs

func (datastore *FileDatastoreImpl) GetJobs(ctx context.Context, kind string, parameters map[string]interface{}) []*model.Job

func (*FileDatastoreImpl) GetNextJob

func (datastore *FileDatastoreImpl) GetNextJob(ctx context.Context, nodeId string) *model.Job

func (*FileDatastoreImpl) GetNodes

func (datastore *FileDatastoreImpl) GetNodes(ctx context.Context) []*model.Node

func (*FileDatastoreImpl) GetPacketStream

func (datastore *FileDatastoreImpl) GetPacketStream(ctx context.Context, jobId int, unwrap bool) (io.ReadCloser, string, int64, error)

func (*FileDatastoreImpl) GetPackets

func (datastore *FileDatastoreImpl) GetPackets(ctx context.Context, jobId int, offset int, count int, unwrap bool) ([]*model.Packet, error)

func (*FileDatastoreImpl) Init

func (datastore *FileDatastoreImpl) Init(cfg module.ModuleConfig) error

func (*FileDatastoreImpl) SavePacketStream

func (datastore *FileDatastoreImpl) SavePacketStream(ctx context.Context, jobId int, reader io.ReadCloser) error

func (*FileDatastoreImpl) UpdateJob

func (datastore *FileDatastoreImpl) UpdateJob(ctx context.Context, job *model.Job) error

func (*FileDatastoreImpl) UpdateNode

func (datastore *FileDatastoreImpl) UpdateNode(ctx context.Context, newNode *model.Node) (*model.Node, error)