Documentation ¶
Overview ¶
Consumer client (Analytics application)
Producer client (camera & edgenode functionality)
Index ¶
- Variables
- type Authentication
- type 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 (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)
Constants ¶
This section is empty.
Variables ¶
View Source
var NumImRcvdUnsubTest uint64
Functions ¶
This section is empty.
Types ¶
type Authentication ¶
type Authentication struct {
// contains filtered or unexported fields
}
Authentication holds the login/password
func (*Authentication) GetRequestMetadata ¶
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
Click to show internal directories.
Click to hide internal directories.