service

package
v1.2.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 28, 2022 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Handle

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

func NewHandle

func NewHandle(opts ...HandleOption) *Handle

func (*Handle) Add

func (h *Handle) Add(ctx context.Context, addReq *pb.AddReq) (*pb.AddResp, error)

func (*Handle) Get

func (h *Handle) Get(ctx context.Context, req *pb.RetrieveReq) (*pb.Task, error)

func (*Handle) Remove

func (h *Handle) Remove(ctx context.Context, req *pb.RemoveReq) (*empty.Empty, error)

type HandleOption

type HandleOption func(*Handle)

func HandleOptionTransporters

func HandleOptionTransporters(ts transport.TransporterM) HandleOption

func HandleOptionWithBaseTime

func HandleOptionWithBaseTime(base time.Duration) HandleOption

func HandleOptionWithGP

func HandleOptionWithGP(gp limiter.Pool) HandleOption

func HandleOptionWithIdCreator

func HandleOptionWithIdCreator(version role.GenerateIds) HandleOption

func HandleOptionWithLogger

func HandleOptionWithLogger(logger system.Logger) HandleOption

func HandleOptionWithRunner

func HandleOptionWithRunner(runner task.Runner) HandleOption

func HandleOptionWithStore

func HandleOptionWithStore(store role.DataStore) HandleOption

func HandleOptionWithTimeOut

func HandleOptionWithTimeOut(to time.Duration) HandleOption

func HandleOptionWithTimer

func HandleOptionWithTimer(timer timer.Scanner) HandleOption

func HandleOptionWithTp

func HandleOptionWithTp(tp task.Factory) HandleOption

func HandleOptionWithWait

func HandleOptionWithWait(wait bool) HandleOption

func HandleOptionWithXCopy

func HandleOptionWithXCopy(c xcopy.XCopy) HandleOption

Jump to

Keyboard shortcuts

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