client

Documentation

Overview

Consumer client (Analytics application)

Producer client (camera & edgenode functionality)

Index

• Variables
• type Authentication
  • func (a *Authentication) GetRequestMetadata(context.Context, ...string) (map[string]string, error)
  • func (a *Authentication) RequireTransportSecurity() bool
• type ConsumerClient
  • func NewConsumerClient(login, password string) *ConsumerClient
  • func (cc *ConsumerClient) Connect(url, userAddress string) error
  • func (cc *ConsumerClient) Retry(url, userAddress string, numRetries int) (err error)
  • func (cc *ConsumerClient) SubscribeImage(client edgeserver.PubSubClient, tbegin time.Time) error
  • func (cc *ConsumerClient) SubscribeImageTest(client edgenode.PubSubClient, camid, latency, accuracy, tStart, tStop string) (string, []string, []int, uint64)
  • func (cc *ConsumerClient) SubscribeImageTestConcurrent(client edgenode.PubSubClient, camid, latency, accuracy, tStart, tStop string)
  • func (cc *ConsumerClient) SubscribeImageTestESB(client edgeserver.PubSubClient, camid, latency, accuracy, tStart, tStop string) (string, []string, []int, uint64)
  • func (cc *ConsumerClient) Unsubscribe(client edgeserver.PubSubClient)
• type ProducerClient
  • func NewProducerClient(login, password string) *ProducerClient
  • func (pc *ProducerClient) Connect(url, userAddress string) error
  • func (pc *ProducerClient) PublishImage(client edgenode.PubSubClient) error
  • func (pc *ProducerClient) PublishImageTest(client edgenode.PubSubClient, imageFilesPath string, ...) (string, []string, []int, uint64)
  • func (pc *ProducerClient) PublishImageTestConcurrent(client edgenode.PubSubClient, imageFilesPath string, ...)
  • func (pc *ProducerClient) PublishImageTestESB(client edgenode.PubSubClient, imageFilesPath string, ...) error
  • func (pc *ProducerClient) Retry(url, userAddress string, numRetries int) (err error)

Variables

var NumImRcvdUnsubTest uint64

Types

type Authentication

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

Authentication holds the login/password

func (*Authentication) GetRequestMetadata

func (a *Authentication) GetRequestMetadata(context.Context, ...string) (map[string]string, error)

GetRequestMetadata gets the current request metadata

func (*Authentication) RequireTransportSecurity

func (a *Authentication) RequireTransportSecurity() bool

RequireTransportSecurity indicates whether the credentials requires transport security

type ConsumerClient

type ConsumerClient struct {
	Auth           Authentication
	ConnConsClient *grpc.ClientConn
	Cl             edgeserver.PubSubClient
	Cancel         context.CancelFunc
	Ctx            context.Context
}

func NewConsumerClient

func NewConsumerClient(login, password string) *ConsumerClient

func (*ConsumerClient) Connect

func (cc *ConsumerClient) Connect(url, userAddress string) error

func (*ConsumerClient) Retry

func (cc *ConsumerClient) Retry(url, userAddress string, numRetries int) (err error)

func (*ConsumerClient) SubscribeImage

func (cc *ConsumerClient) SubscribeImage(client edgeserver.PubSubClient, tbegin time.Time) error

func (*ConsumerClient) SubscribeImageTest

func (cc *ConsumerClient) SubscribeImageTest(client edgenode.PubSubClient, camid, latency, accuracy, tStart, tStop string) (string, []string, []int, uint64)

func (*ConsumerClient) SubscribeImageTestConcurrent

func (cc *ConsumerClient) SubscribeImageTestConcurrent(client edgenode.PubSubClient, camid, latency, accuracy, tStart, tStop string)

func (*ConsumerClient) SubscribeImageTestESB

func (cc *ConsumerClient) SubscribeImageTestESB(client edgeserver.PubSubClient, camid, latency, accuracy,
	tStart, tStop string) (string, []string, []int, uint64)

func (*ConsumerClient) Unsubscribe

func (cc *ConsumerClient) Unsubscribe(client edgeserver.PubSubClient)

type ProducerClient

type ProducerClient struct {
	Auth           Authentication
	ConnProdClient *grpc.ClientConn
	Cl             edgenode.PubSubClient
	Cancel         context.CancelFunc
	Ctx            context.Context
}

func NewProducerClient

func NewProducerClient(login, password string) *ProducerClient

func (*ProducerClient) Connect

func (pc *ProducerClient) Connect(url, userAddress string) error

func (*ProducerClient) PublishImage

func (pc *ProducerClient) PublishImage(client edgenode.PubSubClient) error

func (*ProducerClient) PublishImageTest

func (pc *ProducerClient) PublishImageTest(client edgenode.PubSubClient, imageFilesPath string, numImagesInsert,
	frameRate uint64, imSizeParam string) (string, []string, []int, uint64)

func (*ProducerClient) PublishImageTestConcurrent

func (pc *ProducerClient) PublishImageTestConcurrent(client edgenode.PubSubClient, imageFilesPath string, numImagesInsert,
	frameRate uint64, imSizeParam string)

func (*ProducerClient) PublishImageTestESB

func (pc *ProducerClient) PublishImageTestESB(client edgenode.PubSubClient, imageFilesPath string, numImagesInsert,
	frameRate uint64, imSizeParam string) error

func (*ProducerClient) Retry

func (pc *ProducerClient) Retry(url, userAddress string, numRetries int) (err error)