remotecluster

package

v0.0.0-...-8391792 Latest Latest Go to latest Published: Nov 1, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func ObjID(clusterID, ns, name string, uid types.UID) string

type Event struct {
	Cluster *RemoteCluster
	Type    EventType
	ObjType ObjectType
	Objs    []interface{}
	ObjID   string
}

func (ev *Event) ToAdded() *Event

func (ev *Event) ToUpdatedFrom(oldObj interface{}) *Event

type EventType string

const (
	AddEvent    EventType = "Added"
	DeleteEvent EventType = "Deleted"
	UpdateEvent EventType = "Updated"
)

type ObjectType string

const (
	NetworkPolicy ObjectType = "np"
	Pod           ObjectType = "pod"
)

type RemoteCluster struct {
	ClusterID string
	ClientSet kubernetes.Interface
	// contains filtered or unexported fields
}

func New(clusterID string, clientSet kubernetes.Interface) *RemoteCluster

func (rc *RemoteCluster) Delete(np *v1net.NetworkPolicy) error

func (rc *RemoteCluster) Distribute(np *v1net.NetworkPolicy) error

func (rc *RemoteCluster) GetNetworkPolicies() []interface{}

func (rc *RemoteCluster) GetPods() []interface{}

func (rc *RemoteCluster) HasSynced() bool

func (rc *RemoteCluster) NewAddEvent(objInterface interface{}) *Event

func (rc *RemoteCluster) NewDeleteEvent(objInterface interface{}) *Event

func (rc *RemoteCluster) NewUpdateEvent(objInterface, newObjInterface interface{}) *Event

func (rc *RemoteCluster) OnAdd(obj interface{}, _ bool)

func (rc *RemoteCluster) OnDelete(obj interface{})

func (rc *RemoteCluster) OnUpdate(oldObj, newObj interface{})

func (rc *RemoteCluster) Run(onSyncDoneFunc func(resourceWatcher *RemoteCluster))

func (rc *RemoteCluster) SetEventChannel(eventChan chan *Event)

func (rc *RemoteCluster) Stop()

Stop will stop the running informers.

func (rc *RemoteCluster) Stopped() bool