grpc

Documentation

Index

• Constants
• type FlagSyncServiceClient
• type FlagSyncServiceClientResponse
• 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 FlagSyncServiceClient

type FlagSyncServiceClient interface {
	syncv1grpc.FlagSyncServiceClient
}

type FlagSyncServiceClientResponse

type FlagSyncServiceClientResponse interface {
	syncv1grpc.FlagSyncService_SyncFlagsClient
}

type Sync

type Sync struct {
	CertPath          string
	CredentialBuilder grpccredential.Builder
	Logger            *logger.Logger
	ProviderID        string
	Secure            bool
	Selector          string
	URI               string
	// 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