captain

package
v0.4.9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 16, 2022 License: AGPL-3.0 Imports: 45 Imported by: 3

Documentation

Index

Constants

View Source 
const GossipOpType string = "gossip"

GossipOpType is the type ID of the gossip operation.

View Source 
const GossipQueryOpType string = "gossip/query"

GossipQueryOpType is the type ID of the gossip query operation.

View Source 
const PublishOpType string = "publish"

PublishOpType is the type ID of the publish operation.

Variables

View Source 
var (
	// CfgOptionEnableSPNKey is the configuration key for the SPN module.
	CfgOptionEnableSPNKey = "spn/enable"

	// CfgOptionHomeHubPolicyKey is the configuration key for the SPN home policy.
	CfgOptionHomeHubPolicyKey = "spn/homePolicy"

	// CfgOptionDNSExitHubPolicyKey is the configuration key for the SPN DNS exit policy.
	CfgOptionDNSExitHubPolicyKey = "spn/dnsExitPolicy"
)
View Source 
var ErrAllHomeHubsExcluded = errors.New("all home hubs are excluded")

ErrAllHomeHubsExcluded is returned when all available home hubs were excluded.

Functions

func AddToDebugInfo added in v0.4.4 

func AddToDebugInfo(di *debug.Info)

AddToDebugInfo adds the SPN status to the given debug.Info.

func ClientBootstrapping added in v0.3.8 

func ClientBootstrapping() bool

ClientBootstrapping signifies if the SPN is currently bootstrapping and requires normal connectivity for download assets.

func ClientReady 

func ClientReady() bool

ClientReady signifies if the SPN client is fully ready to handle connections.

func EstablishCrane added in v0.3.0 

func EstablishCrane(ctx context.Context, dst *hub.Hub) (*docks.Crane, error)

EstablishCrane establishes a crane to another Hub.

func EstablishPublicLane added in v0.3.0 

func EstablishPublicLane(ctx context.Context, dst *hub.Hub) (*docks.Crane, *terminal.Error)

EstablishPublicLane establishes a crane to another Hub and publishes it.

func GetDNSExitHubPolicy added in v0.4.3 

func GetDNSExitHubPolicy() (endpoints.Endpoints, error)

GetDNSExitHubPolicy return the current DNS exit policy.

func IsExcepted added in v0.3.0 

func IsExcepted(ip net.IP) bool

IsExcepted checks if the given IP is currently excepted from the SPN.

Types

type BootstrapFile 

type BootstrapFile struct {
	Main BootstrapFileEntry
}

BootstrapFile is used for sideloading bootstrap data.

type BootstrapFileEntry added in v0.3.0 

type BootstrapFileEntry struct {
	Hubs []string
}

BootstrapFileEntry is the bootstrap data structure for one map.

type GossipMsgType added in v0.3.0 

type GossipMsgType uint8

GossipMsgType is the gossip message type. 

const (
	GossipHubAnnouncementMsg GossipMsgType = 1
	GossipHubStatusMsg       GossipMsgType = 2
)

Gossip Message Types.

func (GossipMsgType) String added in v0.3.0 

func (msgType GossipMsgType) String() string

type GossipOp added in v0.3.0 

type GossipOp struct {
	terminal.OpBase
	// contains filtered or unexported fields
}

GossipOp is used to gossip Hub messages.

func NewGossipOp added in v0.3.0 

func NewGossipOp(controller *docks.CraneControllerTerminal) (*GossipOp, *terminal.Error)

NewGossipOp start a new gossip operation.

func (*GossipOp) Deliver added in v0.3.0 

func (op *GossipOp) Deliver(c *container.Container) *terminal.Error

Deliver delivers a message to the operation.

func (*GossipOp) End added in v0.3.0 

func (op *GossipOp) End(err *terminal.Error)

End ends the operation.

func (*GossipOp) Type added in v0.3.0 

func (op *GossipOp) Type() string

Type returns the type ID.

type GossipQueryOp added in v0.3.0 

type GossipQueryOp struct {
	terminal.OpBase
	// contains filtered or unexported fields
}

GossipQueryOp is used to query gossip messages.

func NewGossipQueryOp added in v0.3.0 

func NewGossipQueryOp(t terminal.OpTerminal) (*GossipQueryOp, *terminal.Error)

NewGossipQueryOp starts a new gossip query operation.

func (*GossipQueryOp) Deliver added in v0.3.0 

func (op *GossipQueryOp) Deliver(c *container.Container) *terminal.Error

Deliver delivers the message to the operation.

func (*GossipQueryOp) End added in v0.3.0 

func (op *GossipQueryOp) End(err *terminal.Error)

End ends the operation.

func (*GossipQueryOp) Type added in v0.3.0 

func (op *GossipQueryOp) Type() string

Type returns the type ID.

type PublishOp added in v0.3.0 

type PublishOp struct {
	terminal.OpBase
	// contains filtered or unexported fields
}

PublishOp is used to publish a connection.

func NewPublishOp added in v0.3.0 

func NewPublishOp(controller *docks.CraneControllerTerminal, identity *cabin.Identity) (*PublishOp, *terminal.Error)

NewPublishOp start a new publish operation.

func (*PublishOp) Deliver added in v0.3.0 

func (op *PublishOp) Deliver(c *container.Container) *terminal.Error

Deliver delivers a message to the operation.

func (*PublishOp) End added in v0.3.0 

func (op *PublishOp) End(tErr *terminal.Error)

End ends the operation.

func (*PublishOp) Result added in v0.3.0 

func (op *PublishOp) Result() <-chan *terminal.Error

Result returns the result (end error) of the operation.

func (*PublishOp) Type added in v0.3.0 

func (op *PublishOp) Type() string

Type returns the type ID.

type SPNStatus added in v0.3.7 

type SPNStatus struct {
	record.Base
	sync.Mutex

	Status             SPNStatusName
	HomeHubID          string
	HomeHubName        string
	ConnectedIP        string
	ConnectedTransport string
	ConnectedSince     *time.Time
}

SPNStatus holds SPN status information.

type SPNStatusName added in v0.3.7 

type SPNStatusName string

SPNStatusName is a SPN status. 

const (
	StatusFailed     SPNStatusName = "failed"
	StatusDisabled   SPNStatusName = "disabled"
	StatusConnecting SPNStatusName = "connecting"
	StatusConnected  SPNStatusName = "connected"
)

SPN Stati.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.