push

type Client interface {
	// Dial establishes a connection with the push backend
	Dial() error
	// ActivateSubscription provides the push backend
	// with all the necessary information to start the push functionality for the respective subscription
	ActivateSubscription(ctx context.Context, subscription subscriptions.Subscription) ClientStatus
	// DeactivateSubscription asks the push backend to stop the push functionality for the respective subscription
	DeactivateSubscription(ctx context.Context, fullSub string) ClientStatus
	// SubscriptionStatus returns the current push status oif the given subscription
	SubscriptionStatus(ctx context.Context, fullSub string) ClientStatus
	// HealthCheck performs the grpc health check call
	HealthCheck(ctx context.Context) ClientStatus
	// Target returns the endpoint the client has been connected to
	Target() string
	// Close closes the connection with the push backend
	Close()
}

type ClientStatus interface {
	// Result returns the string representation for the response from a push backend
	Result(details bool) string
}

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

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

type MockClient struct{}

type MockClientStatus struct {
	Status string
}