binder

Documentation

Index

• Constants
• func NewWatcher(path string) watcher
• type Binder
  • func NewBinder(searchPath string) Binder
• type Credentials
  • func CallerFromAuthInfo(ainfo credentials.AuthInfo) (Credentials, bool)
  • func CallerFromContext(ctx context.Context) (Credentials, bool)
  • func (c Credentials) AuthType() string
• type Operation

Constants

const CredentialsExtension = ".json"

const CredentialsSubdir = "creds"

const MountSubdir = "mount"

const PollSleepTime = 100 * time.Millisecond

const SocketFilename = "socket"

Functions

func NewWatcher

func NewWatcher(path string) watcher

Types

type Binder

type Binder interface {

	// Returns the gRPC server for this Binder. Used to register the service to be provided to workloads.
	Server() *grpc.Server

	// The path this Binder is searching for workload mounts on.
	SearchPath() string

	// Search for pod mounts to bind sockets in.
	// Send a wait group over the stop channel to gracefully cancel.  The receiver
	// should call Done() on the wait group when its shutdown is complete.
	SearchAndBind(stop <-chan *sync.WaitGroup)
}

func NewBinder

func NewBinder(searchPath string) Binder

type Credentials

type Credentials struct {
	Uid            string
	Workload       string
	Namespace      string
	ServiceAccount string
}

TODO relocate to shared location

func CallerFromAuthInfo

func CallerFromAuthInfo(ainfo credentials.AuthInfo) (Credentials, bool)

func CallerFromContext

func CallerFromContext(ctx context.Context) (Credentials, bool)

func (Credentials) AuthType

func (c Credentials) AuthType() string

type Operation

type Operation int

const (
	Added Operation = iota
	Removed
)