gs

Documentation

Index

• func RegisterServers(servers []string)
• type BothWorker
  • func NewBothWorker(client *Client, tag string, sender func(chan<- *api.Task), ...) *BothWorker
  • func (w *BothWorker) GetName() string
  • func (w *BothWorker) Run(ctx context.Context)
• type Client
  • func NewClient(server string) *Client
  • func NewClientWithLB(servers ...string) *Client
  • func (c *Client) SendOneTask(task *api.Task) error
  • func (c *Client) SendTasks(tasks []*api.Task) error
• type GazerSystemResolver
  • func (*GazerSystemResolver) Close()
  • func (r *GazerSystemResolver) ResolveNow(_ resolver.ResolveNowOptions)
• type GazerSystemResolverBuilder
  • func (b *GazerSystemResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, _ resolver.BuildOptions) (resolver.Resolver, error)
  • func (*GazerSystemResolverBuilder) Scheme() string
• type ParserUnit
• type ParserWorker
  • func NewParserWorker(gazerSystemClient *Client, tag string, parser func(*api.Raw, *Client) error) *ParserWorker
  • func (p *ParserWorker) GetName() string
  • func (p *ParserWorker) Run(ctx context.Context)
• type SenderUnit
• type SenderWorker
  • func NewSenderWorker(client *Client, name string, sender func(chan<- *api.Task)) *SenderWorker
  • func (s *SenderWorker) GetName() string
  • func (s *SenderWorker) Run(ctx context.Context)
• type WorkUnit
• type Worker
• type WorkerGroup
  • func NewWorkerGroup(servers ...string) *WorkerGroup
  • func (g *WorkerGroup) AddByWorkUnit(w WorkUnit)
  • func (g *WorkerGroup) AddWorker(targetURL string, sender func(chan<- *api.Task), ...)
  • func (g *WorkerGroup) Run(ctx context.Context)

Functions

func RegisterServers

func RegisterServers(servers []string)

Types

type BothWorker

type BothWorker struct {
	Client       *Client
	SenderWorker *SenderWorker
	ParserWorker *ParserWorker
	// contains filtered or unexported fields
}

func NewBothWorker

func NewBothWorker(client *Client, tag string, sender func(chan<- *api.Task), parser func(*api.Raw, *Client) error) *BothWorker

func (*BothWorker) GetName

func (w *BothWorker) GetName() string

func (*BothWorker) Run

func (w *BothWorker) Run(ctx context.Context)

type Client

type Client struct {
	api.GazerSystemClient
}

func NewClient

func NewClient(server string) *Client

func NewClientWithLB

func NewClientWithLB(servers ...string) *Client

func (*Client) SendOneTask

func (c *Client) SendOneTask(task *api.Task) error

func (*Client) SendTasks

func (c *Client) SendTasks(tasks []*api.Task) error

type GazerSystemResolver

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

GazerSystemResolver Resolver(https://godoc.org/google.golang.org/grpc/resolver#Resolver).

func (*GazerSystemResolver) Close

func (*GazerSystemResolver) Close()

func (*GazerSystemResolver) ResolveNow

func (r *GazerSystemResolver) ResolveNow(_ resolver.ResolveNowOptions)

type GazerSystemResolverBuilder

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

GazerSystemResolverBuilder ResolverBuilder(https://godoc.org/google.golang.org/grpc/resolver#Builder).

func (*GazerSystemResolverBuilder) Build

func (b *GazerSystemResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, _ resolver.BuildOptions) (resolver.Resolver, error)

func (*GazerSystemResolverBuilder) Scheme

func (*GazerSystemResolverBuilder) Scheme() string

type ParserUnit

type ParserUnit interface {
	WorkUnit
	Parser(raw *api.Raw, client Client) error
	GetTargetURL() *url.URL
}

type ParserWorker

type ParserWorker struct {
	Client *Client
	Tag    string

	Parser func(*api.Raw, *Client) error
	// contains filtered or unexported fields
}

func NewParserWorker

func NewParserWorker(gazerSystemClient *Client, tag string, parser func(*api.Raw, *Client) error) *ParserWorker

func (*ParserWorker) GetName

func (p *ParserWorker) GetName() string

func (*ParserWorker) Run

func (p *ParserWorker) Run(ctx context.Context)

type SenderUnit

type SenderUnit interface {
	WorkUnit
	Sender(chan<- string)
}

type SenderWorker

type SenderWorker struct {
	Client      *Client
	TaskChannel chan *api.Task
	Sender      func(chan<- *api.Task)
	// contains filtered or unexported fields
}

func NewSenderWorker

func NewSenderWorker(client *Client, name string, sender func(chan<- *api.Task)) *SenderWorker

func (*SenderWorker) GetName

func (s *SenderWorker) GetName() string

func (*SenderWorker) Run

func (s *SenderWorker) Run(ctx context.Context)

type WorkUnit

type WorkUnit interface {
	Run(ctx context.Context)
	GetName() string
}

type Worker

type Worker interface {
	Run(ctx context.Context)
}

type WorkerGroup

type WorkerGroup struct {
	WorkerList []WorkUnit
	Server     string
	Client     *Client
}

func NewWorkerGroup

func NewWorkerGroup(servers ...string) *WorkerGroup

func (*WorkerGroup) AddByWorkUnit

func (g *WorkerGroup) AddByWorkUnit(w WorkUnit)

func (*WorkerGroup) AddWorker

func (g *WorkerGroup) AddWorker(targetURL string, sender func(chan<- *api.Task), parser func(*api.Raw, *Client) error)

func (*WorkerGroup) Run

func (g *WorkerGroup) Run(ctx context.Context)