consumer

Documentation

Overview

Package esconsumer contains events esconsumer for events

Adapted for Orb project, modifications licensed under MPL v. 2.0:

This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at https://mozilla.org/MPL/2.0/.

Index

• type Subscriber
  • func NewEventStore(client *redis.Client, kubecontrol kubecontrol.Service, esconsumer string, ...) Subscriber

Types

type Subscriber

type Subscriber interface {
	CreateDeploymentEntry(ctx context.Context, sinkId, sinkUrl, sinkUsername, sinkPassword string) error
	GetDeploymentEntryFromSinkId(ctx context.Context, sinkId string) (string, error)
	SubscribeSinks(context context.Context) error
	SubscribeSinker(context context.Context) error
}

func NewEventStore

func NewEventStore(client *redis.Client, kubecontrol kubecontrol.Service, esconsumer string, sinksClient sinkspb.SinkServiceClient, logger *zap.Logger) Subscriber