impl

Documentation

Index

• type Impl
  • func (i *Impl) Init()
  • func (i *Impl) Name() string
  • func (i *Impl) Priority() int
  • func (i *Impl) Read(ctx context.Context, request *bridge.ReadRequest) (*event.Event, error)
  • func (i *Impl) Write(ctx context.Context, event *event.Event) (*bridge.WriteResponse, error)

Types

type Impl

type Impl struct {
	ioc.ObjectImpl
	bridge.UnimplementedRpcServer

	Topic    string `json:"topic" yaml:"topic"`
	Duration int64  `json:"duration" yaml:"duration"` // 将数据从kafka 读出、而后塞入Mysql 的过程中，如果发生失败，需要等待多长时间再次处理
	// contains filtered or unexported fields
}

func (*Impl) Init

func (i *Impl) Init()

func (*Impl) Name

func (i *Impl) Name() string

func (*Impl) Priority

func (i *Impl) Priority() int

func (*Impl) Read

func (i *Impl) Read(ctx context.Context, request *bridge.ReadRequest) (*event.Event, error)

func (*Impl) Write

func (i *Impl) Write(ctx context.Context, event *event.Event) (*bridge.WriteResponse, error)