observers

Documentation

Index

• Variables
• type SessionProvider
• type StackSession
• type StackUpdateEvent
  • func (*StackUpdateEvent) Descriptor() ([]byte, []int)
  • func (x *StackUpdateEvent) GetDeployed() bool
  • func (x *StackUpdateEvent) GetDeployedRevision() uint64
  • func (x *StackUpdateEvent) GetEnv() *schema.Environment
  • func (x *StackUpdateEvent) GetFocus() []string
  • func (x *StackUpdateEvent) GetNetworkPlan() *storage.NetworkPlan
  • func (x *StackUpdateEvent) GetStack() *schema.Stack
  • func (*StackUpdateEvent) ProtoMessage()
  • func (x *StackUpdateEvent) ProtoReflect() protoreflect.Message
  • func (x *StackUpdateEvent) Reset()
  • func (x *StackUpdateEvent) String() string
• type StaticProvider
  • func Static() *StaticProvider
  • func (p *StaticProvider) NewStackClient() (StackSession, error)
  • func (p *StaticProvider) PushUpdate(update *StackUpdateEvent)
  • func (p *StaticProvider) RemoveClient(ch chan *StackUpdateEvent)

Variables

var File_internal_observers_types_proto protoreflect.FileDescriptor

Types

type SessionProvider

type SessionProvider interface {
	NewStackClient() (StackSession, error)
}

type StackSession

type StackSession interface {
	StackEvents() chan *StackUpdateEvent
	Close()
}

type StackUpdateEvent

type StackUpdateEvent struct {
	Env              *schema.Environment  `protobuf:"bytes,1,opt,name=env,proto3" json:"env,omitempty"`
	Stack            *schema.Stack        `protobuf:"bytes,2,opt,name=stack,proto3" json:"stack,omitempty"`
	Focus            []string             `protobuf:"bytes,3,rep,name=focus,proto3" json:"focus,omitempty"`
	NetworkPlan      *storage.NetworkPlan `protobuf:"bytes,4,opt,name=network_plan,json=networkPlan,proto3" json:"network_plan,omitempty"`
	Deployed         bool                 `protobuf:"varint,5,opt,name=deployed,proto3" json:"deployed,omitempty"`
	DeployedRevision uint64               `protobuf:"varint,6,opt,name=deployed_revision,json=deployedRevision,proto3" json:"deployed_revision,omitempty"`
	// contains filtered or unexported fields
}

func (*StackUpdateEvent) Descriptor

func (*StackUpdateEvent) Descriptor() ([]byte, []int)

Deprecated: Use StackUpdateEvent.ProtoReflect.Descriptor instead.

func (*StackUpdateEvent) GetDeployed

func (x *StackUpdateEvent) GetDeployed() bool

func (*StackUpdateEvent) GetDeployedRevision

func (x *StackUpdateEvent) GetDeployedRevision() uint64

func (*StackUpdateEvent) GetEnv

func (x *StackUpdateEvent) GetEnv() *schema.Environment

func (*StackUpdateEvent) GetFocus

func (x *StackUpdateEvent) GetFocus() []string

func (*StackUpdateEvent) GetNetworkPlan

func (x *StackUpdateEvent) GetNetworkPlan() *storage.NetworkPlan

func (*StackUpdateEvent) GetStack

func (x *StackUpdateEvent) GetStack() *schema.Stack

func (*StackUpdateEvent) ProtoMessage

func (*StackUpdateEvent) ProtoMessage()

func (*StackUpdateEvent) ProtoReflect

func (x *StackUpdateEvent) ProtoReflect() protoreflect.Message

func (*StackUpdateEvent) Reset

func (x *StackUpdateEvent) Reset()

func (*StackUpdateEvent) String

func (x *StackUpdateEvent) String() string

type StaticProvider

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

func Static

func Static() *StaticProvider

func (*StaticProvider) NewStackClient

func (p *StaticProvider) NewStackClient() (StackSession, error)

func (*StaticProvider) PushUpdate

func (p *StaticProvider) PushUpdate(update *StackUpdateEvent)

func (*StaticProvider) RemoveClient

func (p *StaticProvider) RemoveClient(ch chan *StackUpdateEvent)