grpc

Documentation

Index

• Constants
• 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 standard prefix. This prefix helps to differentiate remote
	// URLs for REST APIs (i.e - HTTP) from GRPC endpoints.
	Prefix       = "grpc://"
	PrefixSecure = "grpcs://"
)

Types

type Sync

type Sync struct {
	URI        string
	ProviderID string
	CertPath   string
	Logger     *logger.Logger
	// 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