Documentation ¶
Index ¶
- type GitProcessor
- func (g *GitProcessor) Configure(config interface{}) error
- func (g *GitProcessor) GetConfig() interface{}
- func (g *GitProcessor) GetError() error
- func (g *GitProcessor) Metadata() processors.Processor
- func (g *GitProcessor) New() simpleprocessor.ChunkProcessor
- func (g *GitProcessor) Output() interface{}
- func (g *GitProcessor) Run(data interface{})
- func (g *GitProcessor) State() <-chan processors.DataChunkState
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GitProcessor ¶
type GitProcessor struct {
// contains filtered or unexported fields
}
func (*GitProcessor) Configure ¶
func (g *GitProcessor) Configure(config interface{}) error
func (*GitProcessor) GetConfig ¶
func (g *GitProcessor) GetConfig() interface{}
func (*GitProcessor) GetError ¶
func (g *GitProcessor) GetError() error
func (*GitProcessor) Metadata ¶
func (g *GitProcessor) Metadata() processors.Processor
func (*GitProcessor) New ¶
func (g *GitProcessor) New() simpleprocessor.ChunkProcessor
func (*GitProcessor) Output ¶
func (g *GitProcessor) Output() interface{}
func (*GitProcessor) Run ¶
func (g *GitProcessor) Run(data interface{})
func (*GitProcessor) State ¶
func (g *GitProcessor) State() <-chan processors.DataChunkState
Click to show internal directories.
Click to hide internal directories.