go_learning

package

v0.0.0-...-096aedc Latest Latest Go to latest Published: May 3, 2021 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/escray/go_learning

Links

Open Source Insights

Documentation ¶

Overview ¶

define the interface and the structures for pipe-filter style implemention

Index ¶

Constants
Variables
func GetFibonacciSerie(n int) []int
type Agent
- func NewAgent(sizeEvtBuf int) *Agent
- func (agt *Agent) Destroy() error
- func (agt *Agent) EventProcessGroutine()
- func (agt *Agent) OnEvent(evt Event)
- func (agt *Agent) RegisterCollector(name string, collector Collector) error
- func (agt *Agent) Start() error
- func (agt *Agent) Stop() error
type BasicInfo
- func (v BasicInfo) MarshalEasyJSON(w *jwriter.Writer)
- func (v BasicInfo) MarshalJSON() ([]byte, error)
- func (v *BasicInfo) UnmarshalEasyJSON(l *jlexer.Lexer)
- func (v *BasicInfo) UnmarshalJSON(data []byte) error
type BasicInfoList
- func (v BasicInfoList) MarshalEasyJSON(w *jwriter.Writer)
- func (v BasicInfoList) MarshalJSON() ([]byte, error)
- func (v *BasicInfoList) UnmarshalEasyJSON(l *jlexer.Lexer)
- func (v *BasicInfoList) UnmarshalJSON(data []byte) error
type Collector
type CollectorsError
- func (ce CollectorsError) Error() string
type EmployeeJSON
- func (v EmployeeJSON) MarshalEasyJSON(w *jwriter.Writer)
- func (v EmployeeJSON) MarshalJSON() ([]byte, error)
- func (v *EmployeeJSON) UnmarshalEasyJSON(l *jlexer.Lexer)
- func (v *EmployeeJSON) UnmarshalJSON(data []byte) error
type Event
type EventReceiver
type Filter
type JobInfo
- func (v JobInfo) MarshalEasyJSON(w *jwriter.Writer)
- func (v JobInfo) MarshalJSON() ([]byte, error)
- func (v *JobInfo) UnmarshalEasyJSON(l *jlexer.Lexer)
- func (v *JobInfo) UnmarshalJSON(data []byte) error
type Request
type Response
type SplitFilter
- func NewSplitFilter(delimiter string) *SplitFilter
- func (sf *SplitFilter) Process(data Request) (Response, error)
type StraightPipeline
- func NewStraightPipeline(name string, filters ...Filter) *StraightPipeline
- func (f *StraightPipeline) Process(data Request) (Response, error)
type SumFilter
- func NewSumFilter() *SumFilter
- func (sf *SumFilter) Process(data Request) (Response, error)
type ToIntFilter
- func NewToIntFilter() *ToIntFilter
- func (tif *ToIntFilter) Process(data Request) (Response, error)

Constants ¶

View Source

const (
	Waiting = iota
	Running
)

Variables ¶

View Source

var ErrorSumFilterWrongFormat = errors.New("input data should be []int")

View Source

var ErrorToIntFilterWrongFormat = errors.New("ipnut data should be []string")

View Source

var ErrorWrongState = errors.New("can not take the operation in the current state")

View Source

var SplitFilterWrongFormatError = errors.New("input data should be string")

Functions ¶

func GetFibonacciSerie ¶

func GetFibonacciSerie(n int) []int

Types ¶

type Agent ¶

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

func NewAgent ¶

func NewAgent(sizeEvtBuf int) *Agent

func (*Agent) Destroy ¶

func (agt *Agent) Destroy() error

func (*Agent) EventProcessGroutine ¶

func (agt *Agent) EventProcessGroutine()

func (*Agent) OnEvent ¶

func (agt *Agent) OnEvent(evt Event)

func (*Agent) RegisterCollector ¶

func (agt *Agent) RegisterCollector(name string, collector Collector) error

func (*Agent) Start ¶

func (agt *Agent) Start() error

func (*Agent) Stop ¶

func (agt *Agent) Stop() error

type BasicInfo ¶

type BasicInfo struct {
	Name string `json:"name"`
	Age  int    `json:"age`
}

func (BasicInfo) MarshalEasyJSON ¶

func (v BasicInfo) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (BasicInfo) MarshalJSON ¶

func (v BasicInfo) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*BasicInfo) UnmarshalEasyJSON ¶

func (v *BasicInfo) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*BasicInfo) UnmarshalJSON ¶

func (v *BasicInfo) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type BasicInfoList ¶

type BasicInfoList []BasicInfo

easyjson:json

func (BasicInfoList) MarshalEasyJSON ¶

func (v BasicInfoList) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (BasicInfoList) MarshalJSON ¶

func (v BasicInfoList) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*BasicInfoList) UnmarshalEasyJSON ¶

func (v *BasicInfoList) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*BasicInfoList) UnmarshalJSON ¶

func (v *BasicInfoList) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type Collector ¶

type Collector interface {
	Init(evtReceiver EventReceiver) error
	Start(agtCtx context.Context) error
	Destroy() error
	Stop() error
}

type CollectorsError ¶

type CollectorsError struct {
	CollectorErrors []error
}

func (CollectorsError) Error ¶

func (ce CollectorsError) Error() string

type EmployeeJSON ¶

type EmployeeJSON struct {
	BasicInfo BasicInfo `json:"basic_info"`
	JobInfo   JobInfo   `json:"job_info"`
}

func (EmployeeJSON) MarshalEasyJSON ¶

func (v EmployeeJSON) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (EmployeeJSON) MarshalJSON ¶

func (v EmployeeJSON) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*EmployeeJSON) UnmarshalEasyJSON ¶

func (v *EmployeeJSON) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*EmployeeJSON) UnmarshalJSON ¶

func (v *EmployeeJSON) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type Event ¶

type Event struct {
	Source  string
	Content string
}

type EventReceiver ¶

type EventReceiver interface {
	OnEvent(evt Event)
}

type Filter ¶

type Filter interface {
	Process(data Request) (Response, error)
}

Filter interface is the definition of the data processing components Pipe-Filter structure

type JobInfo ¶

type JobInfo struct {
	Skills []string `json:"skills"`
}

func (JobInfo) MarshalEasyJSON ¶

func (v JobInfo) MarshalEasyJSON(w *jwriter.Writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (JobInfo) MarshalJSON ¶

func (v JobInfo) MarshalJSON() ([]byte, error)

MarshalJSON supports json.Marshaler interface

func (*JobInfo) UnmarshalEasyJSON ¶

func (v *JobInfo) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*JobInfo) UnmarshalJSON ¶

func (v *JobInfo) UnmarshalJSON(data []byte) error

UnmarshalJSON supports json.Unmarshaler interface

type Request ¶

type Request interface{}

Request is the input of the filter

type Response ¶

type Response interface{}

Response is the output of the filter

type SplitFilter ¶

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

func NewSplitFilter ¶

func NewSplitFilter(delimiter string) *SplitFilter

func (*SplitFilter) Process ¶

func (sf *SplitFilter) Process(data Request) (Response, error)

type StraightPipeline ¶

type StraightPipeline struct {
	Name    string
	Filters *[]Filter
}

func NewStraightPipeline ¶

func NewStraightPipeline(name string, filters ...Filter) *StraightPipeline

func (*StraightPipeline) Process ¶

func (f *StraightPipeline) Process(data Request) (Response, error)

type SumFilter ¶

type SumFilter struct {
}

func NewSumFilter ¶

func NewSumFilter() *SumFilter

func (*SumFilter) Process ¶

func (sf *SumFilter) Process(data Request) (Response, error)

type ToIntFilter ¶

type ToIntFilter struct {
}

func NewToIntFilter ¶

func NewToIntFilter() *ToIntFilter

func (*ToIntFilter) Process ¶

func (tif *ToIntFilter) Process(data Request) (Response, error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
effective_go
web
file
go36
demo03
go_camp
homework/week02
week03
go_mod
hello
morestrings
http
httprouter
httpserver
maps
opt
roa
temp

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL