grpc

Documentation

Index

• Constants
• func URLToGRPCTarget(url string) string
• type Sync
  • func (g *Sync) Init(ctx context.Context) error
  • func (g *Sync) IsReady() bool
  • func (g *Sync) ReSync(ctx context.Context, dataSync chan<- sync.DataSync) error
  • func (g *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error

Constants

const (
	// Prefix for GRPC URL inputs. GRPC does not define a prefix through standard. This prefix helps to differentiate
	// remote URLs for REST APIs (i.e - HTTP) from GRPC endpoints.
	Prefix = "grpc://"
)

Functions

func URLToGRPCTarget

func URLToGRPCTarget(url string) string

URLToGRPCTarget is a helper to derive GRPC target from a provided URL For example, function returns the target localhost:9090 for the input grpc://localhost:9090

Types

type Sync

type Sync struct {
	Target     string
	ProviderID string
	Logger     *logger.Logger

	Mux *msync.RWMutex
	// contains filtered or unexported fields
}

func (*Sync) Init

func (g *Sync) Init(ctx context.Context) error

func (*Sync) IsReady

func (g *Sync) IsReady() bool

func (*Sync) ReSync

func (g *Sync) ReSync(ctx context.Context, dataSync chan<- sync.DataSync) error

func (*Sync) Sync

func (g *Sync) Sync(ctx context.Context, dataSync chan<- sync.DataSync) error