remote_conn

Documentation

Index

• Constants
• func ReturnConnLicense()
• func WaitForConnectionLicense()
• type Dialogue
  • func (s Dialogue) Close() (err error)
  • func (d Dialogue) GetAngeboren() schnittstellen.Angeboren
  • func (s Dialogue) Read(p []byte) (n int, err error)
  • func (s Dialogue) Receive(e any) (err error)
  • func (s Dialogue) Send(e any) (err error)
  • func (s Dialogue) Type() DialogueType
  • func (s Dialogue) Write(p []byte) (n int, err error)
• type DialogueType
  • func (i DialogueType) String() string
• type Listener
• type MessageHiCommander
• type MessageHiSoldier
• type Script
• type SoldierDialogueChanElement
• type StageCommander
  • func MakeStageCommander(u *umwelt.Umwelt, from string, command string) (s *StageCommander, err error)
  • func (s StageCommander) ChanRemoteCommandDone() <-chan struct{}
  • func (s StageCommander) Close() (err error)
  • func (s StageCommander) MainDialogue() Dialogue
  • func (c StageCommander) ShouldIgnoreConnectionError(in error) (ok bool)
  • func (s *StageCommander) StartDialogue(t DialogueType) (d Dialogue, err error)
• type StageSoldier
  • func MakeStageSoldier(u *umwelt.Umwelt) (s *StageSoldier, err error)
  • func (s *StageSoldier) AwaitDialogue() (out SoldierDialogueChanElement)
  • func (s StageSoldier) Close() (err error)
  • func (s *StageSoldier) Listen() (err error)
  • func (s StageSoldier) MainDialogue() Dialogue
  • func (s *StageSoldier) RegisterHandler(t DialogueType, h func(Dialogue) error)

Constants

const (
	DialogueTypeMain = DialogueType(iota)
	DialogueTypeSkusForFilter
	DialogueTypeObjekten
	DialogueTypeAkten
	DialogueTypeObjekteReader
	DialogueTypeAkteReader
	DialogueTypeObjekteWriter
	DialogueTypeAkteWriter
	DialogueTypePull
	DialogueTypePullAkte
	DialogueTypePush
	DialogueTypePushObjekten
	DialogueTypePushAkte
	DialogueTypeGetNeededSkus
)

Functions

func ReturnConnLicense

func ReturnConnLicense()

func WaitForConnectionLicense

func WaitForConnectionLicense()

Types

type Dialogue

type Dialogue struct {
	Angeboren schnittstellen.Angeboren
	// contains filtered or unexported fields
}

func (Dialogue) Close

func (s Dialogue) Close() (err error)

func (Dialogue) GetAngeboren

func (d Dialogue) GetAngeboren() schnittstellen.Angeboren

func (Dialogue) Read

func (s Dialogue) Read(p []byte) (n int, err error)

func (Dialogue) Receive

func (s Dialogue) Receive(e any) (err error)

func (Dialogue) Send

func (s Dialogue) Send(e any) (err error)

func (Dialogue) Type

func (s Dialogue) Type() DialogueType

func (Dialogue) Write

func (s Dialogue) Write(p []byte) (n int, err error)

type DialogueType

type DialogueType int

TODO-P4 rename to RemoteRequest

func (DialogueType) String

func (i DialogueType) String() string

type Listener

type Listener interface {
	Listen() error
}

type MessageHiCommander

type MessageHiCommander struct {
	DialogueType
	CliKonfig erworben.Cli
	Angeboren schnittstellen.Angeboren
}

type MessageHiSoldier

type MessageHiSoldier struct {
	Angeboren schnittstellen.Angeboren
}

type Script

type Script interface {
	HandleSenderDialogue(Dialogue) error
	HandleReceiverDialogue(Dialogue) error
}

type SoldierDialogueChanElement

type SoldierDialogueChanElement struct {
	Dialogue
	MessageHiCommander
	// contains filtered or unexported fields
}

type StageCommander

type StageCommander struct {
	Angeboren schnittstellen.AngeborenGetter
	// contains filtered or unexported fields
}

func MakeStageCommander

func MakeStageCommander(
	u *umwelt.Umwelt,
	from string,
	command string,
) (s *StageCommander, err error)

func (StageCommander) ChanRemoteCommandDone

func (s StageCommander) ChanRemoteCommandDone() <-chan struct{}

func (StageCommander) Close

func (s StageCommander) Close() (err error)

func (StageCommander) MainDialogue

func (s StageCommander) MainDialogue() Dialogue

func (StageCommander) ShouldIgnoreConnectionError

func (c StageCommander) ShouldIgnoreConnectionError(in error) (ok bool)

func (*StageCommander) StartDialogue

func (s *StageCommander) StartDialogue(t DialogueType) (d Dialogue, err error)

type StageSoldier

type StageSoldier struct {
	Angeboren schnittstellen.AngeborenGetter
	// contains filtered or unexported fields
}

func MakeStageSoldier

func MakeStageSoldier(u *umwelt.Umwelt) (
	s *StageSoldier,
	err error,
)

func (*StageSoldier) AwaitDialogue

func (s *StageSoldier) AwaitDialogue() (out SoldierDialogueChanElement)

func (StageSoldier) Close

func (s StageSoldier) Close() (err error)

func (*StageSoldier) Listen

func (s *StageSoldier) Listen() (err error)

func (StageSoldier) MainDialogue

func (s StageSoldier) MainDialogue() Dialogue

func (*StageSoldier) RegisterHandler

func (s *StageSoldier) RegisterHandler(
	t DialogueType,
	h func(Dialogue) error,
)