protocbuf

Documentation

Index

• Variables
• func Create(id, name string, v *Config, workers map[eosc.RequireId]eosc.IWorker) (eosc.IWorker, error)
• func NewFactory() eosc.IExtenderDriverFactory
• func Register(register eosc.IExtenderDriverRegister)
• type Config
  • func (c *Config) String() string
• type Worker
  • func (w *Worker) CheckSkill(skill string) bool
  • func (w *Worker) Descriptor() grpcurl.DescriptorSource
  • func (w *Worker) Reset(conf interface{}, workers map[eosc.RequireId]eosc.IWorker) error
  • func (w *Worker) Start() error
  • func (w *Worker) Stop() error

Variables

var DriverName = "protobuf_transcode"

Functions

func Create

func Create(id, name string, v *Config, workers map[eosc.RequireId]eosc.IWorker) (eosc.IWorker, error)

Create 创建service_http驱动的实例

func NewFactory

func NewFactory() eosc.IExtenderDriverFactory

NewFactory 创建service_http驱动工厂

func Register

func Register(register eosc.IExtenderDriverRegister)

Register 注册protobuf驱动工厂

Types

type Config

type Config struct {
	ProtoFiles eosc.EoFiles `json:"proto_files" label:"proto文件列表"`
}

Config protobuf驱动配置

func (*Config) String

func (c *Config) String() string

type Worker

type Worker struct {
	drivers.WorkerBase
	// contains filtered or unexported fields
}

func (*Worker) CheckSkill

func (w *Worker) CheckSkill(skill string) bool

func (*Worker) Descriptor

func (w *Worker) Descriptor() grpcurl.DescriptorSource

func (*Worker) Reset

func (w *Worker) Reset(conf interface{}, workers map[eosc.RequireId]eosc.IWorker) error

func (*Worker) Start

func (w *Worker) Start() error

func (*Worker) Stop

func (w *Worker) Stop() error