client

Documentation

Index

• Constants
• type Manager
  • func New(client *kubego.Client, logger *logger.Logger, rootUsers []string, ...) *Manager
  • func (m *Manager) CreateApp(ctx context.Context, app *kdeploypb.AppConstructor) (*kdeploypb.App, error)
  • func (m *Manager) DeleteApp(ctx context.Context, ref *kdeploypb.AppRef) error
  • func (m *Manager) GetApp(ctx context.Context, ref *kdeploypb.AppRef) (*kdeploypb.App, error)
  • func (r *Manager) GetJWTHash(hash string) (interface{}, bool)
  • func (r *Manager) GetUserInfo(ctx context.Context) map[string]interface{}
  • func (m *Manager) L() *logger.Logger
  • func (m *Manager) ListApps(ctx context.Context, namespace *kdeploypb.Namespace) (*kdeploypb.Apps, error)
  • func (m *Manager) ListNamespaces(ctx context.Context) (*kdeploypb.Namespaces, error)
  • func (r *Manager) SetJWTHash(hash string, userInfo map[string]interface{})
  • func (r *Manager) SetUserInfo(ctx context.Context, userInfoData map[string]interface{}) context.Context
  • func (c *Manager) StreamInterceptor() grpc.StreamServerInterceptor
  • func (m *Manager) StreamLogs(ctx context.Context, ref *kdeploypb.AppRef) (chan string, error)
  • func (c *Manager) UnaryInterceptor() grpc.UnaryServerInterceptor
  • func (m *Manager) UpdateApp(ctx context.Context, app *kdeploypb.AppUpdate) (*kdeploypb.App, error)

Constants

const Always = "Always"

const RWO = "ReadWriteOnce"

Types

type Manager

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

func New

func New(client *kubego.Client, logger *logger.Logger, rootUsers []string, userInfoEndpoint string, authorizers []*trigger.Decision) *Manager

func (*Manager) CreateApp

func (m *Manager) CreateApp(ctx context.Context, app *kdeploypb.AppConstructor) (*kdeploypb.App, error)

func (*Manager) DeleteApp

func (m *Manager) DeleteApp(ctx context.Context, ref *kdeploypb.AppRef) error

func (*Manager) GetApp

func (m *Manager) GetApp(ctx context.Context, ref *kdeploypb.AppRef) (*kdeploypb.App, error)

func (*Manager) GetJWTHash

func (r *Manager) GetJWTHash(hash string) (interface{}, bool)

func (*Manager) GetUserInfo

func (r *Manager) GetUserInfo(ctx context.Context) map[string]interface{}

func (*Manager) L

func (m *Manager) L() *logger.Logger

func (*Manager) ListApps

func (m *Manager) ListApps(ctx context.Context, namespace *kdeploypb.Namespace) (*kdeploypb.Apps, error)

func (*Manager) ListNamespaces

func (m *Manager) ListNamespaces(ctx context.Context) (*kdeploypb.Namespaces, error)

func (*Manager) SetJWTHash

func (r *Manager) SetJWTHash(hash string, userInfo map[string]interface{})

func (*Manager) SetUserInfo

func (r *Manager) SetUserInfo(ctx context.Context, userInfoData map[string]interface{}) context.Context

func (*Manager) StreamInterceptor

func (c *Manager) StreamInterceptor() grpc.StreamServerInterceptor

func (*Manager) StreamLogs

func (m *Manager) StreamLogs(ctx context.Context, ref *kdeploypb.AppRef) (chan string, error)

func (*Manager) UnaryInterceptor

func (c *Manager) UnaryInterceptor() grpc.UnaryServerInterceptor

func (*Manager) UpdateApp

func (m *Manager) UpdateApp(ctx context.Context, app *kdeploypb.AppUpdate) (*kdeploypb.App, error)