rpc

Documentation

Overview

Copyright Jetstack Ltd. See LICENSE for details.

Copyright Jetstack Ltd. See LICENSE for details.

Copyright Jetstack Ltd. See LICENSE for details.

Copyright Jetstack Ltd. See LICENSE for details.

Copyright Jetstack Ltd. See LICENSE for details.

Index

• Constants
• Variables
• func ListenUnixSocket(tarmak Tarmak, socketPath string, stopCh chan struct{}) error
• type BastionInstanceStatusArgs
• type BastionInstanceStatusReply
• type PingArgs
• type PingReply
• type Tarmak
  • func New(cluster interfaces.Cluster) Tarmak
• type VaultClusterStatusArgs
• type VaultClusterStatusReply
• type VaultInstanceRoleArgs
• type VaultInstanceRoleReply

Constants

const (
	ConnectorSocket = "/tmp/tarmak-connector.sock"
	RPCName         = "Tarmak"
	Retries         = 60
)

Variables

var (
	VaultClusterStatusCall     = fmt.Sprintf("%s.VaultClusterStatus", RPCName)
	VaultClusterInitStatusCall = fmt.Sprintf("%s.VaultClusterInitStatus", RPCName)
)

var (
	BastionInstanceStatusCall = fmt.Sprintf("%s.BastionInstanceStatus", RPCName)
)

var (
	PingCall = fmt.Sprintf("%s.Ping", RPCName)
)

var (
	VaultInstanceRole = fmt.Sprintf("%s.VaultInstanceRole", RPCName)
)

Functions

func ListenUnixSocket

func ListenUnixSocket(tarmak Tarmak, socketPath string, stopCh chan struct{}) error

listen to a unix socket

Types

type BastionInstanceStatusArgs

type BastionInstanceStatusArgs struct {
	Username string
	Hostname string
}

type BastionInstanceStatusReply

type BastionInstanceStatusReply struct {
	Status string
}

type PingArgs

type PingArgs struct {
}

type PingReply

type PingReply struct {
	Version string
}

type Tarmak

type Tarmak interface {
	BastionInstanceStatus(*BastionInstanceStatusArgs, *BastionInstanceStatusReply) error
	VaultClusterStatus(*VaultClusterStatusArgs, *VaultClusterStatusReply) error
	VaultClusterInitStatus(*VaultClusterStatusArgs, *VaultClusterStatusReply) error
	VaultInstanceRole(*VaultInstanceRoleArgs, *VaultInstanceRoleReply) error
	Ping(*PingArgs, *PingReply) error
	// contains filtered or unexported methods
}

func New

func New(cluster interfaces.Cluster) Tarmak

type VaultClusterStatusArgs

type VaultClusterStatusArgs struct {
	VaultInternalFQDNs []string
	VaultCA            string
	VaultKMSKeyID      string
	VaultUnsealKeyName string
	Create             bool
}

type VaultClusterStatusReply

type VaultClusterStatusReply struct {
	Status string
}

type VaultInstanceRoleArgs

type VaultInstanceRoleArgs struct {
	VaultClusterName   string
	RoleName           string
	VaultInternalFQDNs []string
	VaultCA            string
	Create             bool
}

type VaultInstanceRoleReply

type VaultInstanceRoleReply struct {
	InitToken string
}