eaa

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

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

type CertsInfo struct {
	CaRootKeyPath     string `json:"CaRootKeyPath"`
	CaRootPath        string `json:"CaRootPath"`
	ServerCertPath    string `json:"ServerCertPath"`
	ServerKeyPath     string `json:"ServerKeyPath"`
	CommonName        string `json:"CommonName"`
	KafkaCAPath       string `json:"KafkaCAPath"`
	KafkaUserCertPath string `json:"KafkaUserCertPath"`
	KafkaUserKeyPath  string `json:"KafkaUserKeyPath"`
}

type Config struct {
	TLSEndpoint        string        `json:"TlsEndpoint"`
	OpenEndpoint       string        `json:"OpenEndpoint"`
	ValidationEndpoint string        `json:"ValidationEndpoint"`
	HeartbeatInterval  util.Duration `json:"HeartbeatInterval"`
	Certs              CertsInfo     `json:"Certs"`
	KafkaBroker        string        `json:"KafkaBroker"`
}

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

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

type Context struct {
	MsgBrokerCtx msgBroker
	// contains filtered or unexported fields
}

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

type KafkaInterface interface {
	DefaultSaramaSubscriberConfig() *sarama.Config
	DefaultSaramaSyncPublisherConfig() *sarama.Config
	NewWithPartitioningMarshaler(generatePartitionKey kafka.GeneratePartitionKey) kafka.MarshalerUnmarshaler
	NewPublisher(config kafka.PublisherConfig, logger watermill.LoggerAdapter) (*kafka.Publisher, error)
	NewSubscriber(config kafka.SubscriberConfig, logger watermill.LoggerAdapter) (*kafka.Subscriber, error)
}

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

type NotificationDescriptor struct {
	// Name of notification
	Name string `json:"name,omitempty"`
	// Version of notification
	Version string `json:"version,omitempty"`
	// Human readable description of notification
	Description string `json:"description,omitempty"`
}

type NotificationFromProducer struct {
	// Name of notification
	Name string `json:"name,omitempty"`
	// Version of notification
	Version string `json:"version,omitempty"`
	// The payload can be any JSON object with a name
	// and version-specific schema.
	Payload json.RawMessage `json:"payload,omitempty"`
}

type NotificationMessage struct {
	Notification *NotificationFromProducer
	URN          *URN
}

type NotificationSubscriptions struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type NotificationToConsumer struct {
	// Name of notification
	Name string `json:"name,omitempty"`
	// Version of notification
	Version string `json:"version,omitempty"`
	// The payload can be any JSON object with a name
	// and version-specific schema.
	Payload json.RawMessage `json:"payload,omitempty"`
	// URN of the producer
	URN URN `json:"producer,omitempty"`
}

type Route struct {
	Name        string
	Method      string
	Pattern     string
	HandlerFunc http.HandlerFunc
}

type Routes []Route

type Service struct {
	URN           *URN                     `json:"urn,omitempty"`
	Description   string                   `json:"description,omitempty"`
	EndpointURI   string                   `json:"endpoint_uri,omitempty"`
	Status        string                   `json:"status,omitempty"`
	Notifications []NotificationDescriptor `json:"notifications,omitempty"`
	Info          json.RawMessage          `json:"info,omitempty"`
}

type ServiceList struct {
	Services []Service `json:"services,omitempty"`
}

type ServiceMessage struct {
	Svc    *Service `json:"service"`
	Action string   `json:"action"`
}

type SubscriberIds []string

type Subscription struct {

	// The name of the producer app. The unique ID is optional for
	// subscribing and if not given will subscribe to any producer in the
	// namespace.
	URN *URN `json:"urn,omitempty"`

	// The list of all notification types registered by all producers in
	// this namespace.
	Notifications []NotificationDescriptor `json:"notifications,omitempty"`
}

type SubscriptionList struct {
	Subscriptions []Subscription `json:"subscriptions,omitempty"`
}

type SubscriptionMessage struct {
	ClientCommonName string
	Subscription     *Subscription
	Action           string
	Scope            string
}

type URN struct {

	// The per-namespace unique portion of the URN that when appended to
	// the namespace with a separator forms the complete URN.
	ID string `json:"id,omitempty"`

	// The non-unique portion of the URN that identifies the class excluding
	// a trailing separator.
	Namespace string `json:"namespace,omitempty"`
}

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