model

Documentation

Index

• type ClientIdentifier
• type DataEntirePushHandler
• type Instance
• type LabelKV
• type NamespacedApp
• type OpenSergoTransportStream
• type SubscribeKind
• type SubscribeRequestHandler
• type SubscribeTarget
  • func (st SubscribeTarget) NamespacedApp() NamespacedApp

Types

type ClientIdentifier

type ClientIdentifier string

ClientIdentifier represents a unique identifier for an OpenSergo client.

type DataEntirePushHandler

type DataEntirePushHandler func(namespace, app, kind string, dataWithVersion *trpb.DataWithVersion, status *trpb.Status, respId string) error

type Instance

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

type LabelKV

type LabelKV struct {
	Key   string
	Value string
}

type NamespacedApp

type NamespacedApp struct {
	Namespace string
	App       string
}

type OpenSergoTransportStream

type OpenSergoTransportStream = trpb.OpenSergoUniversalTransportService_SubscribeConfigServer

type SubscribeKind

type SubscribeKind = string

type SubscribeRequestHandler

type SubscribeRequestHandler func(ClientIdentifier, *trpb.SubscribeRequest, OpenSergoTransportStream) error

type SubscribeTarget

type SubscribeTarget struct {
	Namespace string
	// AppName represents the target app name. Fast path for "app" label.
	AppName string
	// Labels  []LabelKV
	Kind SubscribeKind
}

func (SubscribeTarget) NamespacedApp

func (st SubscribeTarget) NamespacedApp() NamespacedApp