vcservice

Documentation

Index

• Constants
• type AttachedStream
• type Client
  • func (c *Client) AttachStream(id string) *AttachedStream
  • func (c *Client) DetachStream(id string)
  • func (c *Client) Start()
• type Config
• type IVCService
  • func New(cfg *Config) (IVCService, error)

Constants

const (
	// ReconnectSleep determines the length of time to wait between reconnect attempts to dProxy
	ReconnectSleep = time.Second * 5
)

Types

type AttachedStream

type AttachedStream struct {
	EventsCh chan *protos.VCEvent
}

type Client

type Client struct {
	*Config
	Client protos.VCServiceClient
	Conn   *grpc.ClientConn

	EventsCh             chan *protos.VCEvent
	AttachedStreams      map[string]*AttachedStream
	AttachedStreamsMutex *sync.RWMutex
	// contains filtered or unexported fields
}

func (*Client) AttachStream

func (c *Client) AttachStream(id string) *AttachedStream

AttachStream adds a vc-service event listener to the AttachedStreams map which will receive a copy of all VCEvent messages

func (*Client) DetachStream

func (c *Client) DetachStream(id string)

DetachStream removes a vc-service event listener from AttachedStreams map

func (*Client) Start

func (c *Client) Start()

type Config

type Config struct {
	EtcdService      etcd.IEtcd
	ServerOptions    *opts.ServerOptions
	PersistentConfig *config.Config
}

type IVCService

type IVCService interface {
	AttachStream(id string) *AttachedStream
	DetachStream(id string)
}

func New

func New(cfg *Config) (IVCService, error)

New validates CLI options and returns a new Client struct