grpc

Documentation

Index

• func Connect(ctx context.Context, addr string, opts ...grpc.DialOption) (membershipgrpc.ServerClient, error)
• func NewModule(id, serverAddress string, baseUrl *url.URL, production bool, ...) fx.Option
• type Authenticator
• type AuthenticatorFn
  • func BearerAuthenticator(issuer, clientID, clientSecret string) AuthenticatorFn
  • func TokenAuthenticator(token string) AuthenticatorFn
• type K8SClient

Functions

func Connect

func Connect(ctx context.Context, addr string, opts ...grpc.DialOption) (membershipgrpc.ServerClient, error)

func NewModule

func NewModule(id, serverAddress string, baseUrl *url.URL, production bool, authenticator Authenticator, opts ...grpc.DialOption) fx.Option

Types

type Authenticator

type Authenticator interface {
	// contains filtered or unexported methods
}

type AuthenticatorFn

type AuthenticatorFn func(ctx context.Context) (metadata.MD, error)

func BearerAuthenticator

func BearerAuthenticator(issuer, clientID, clientSecret string) AuthenticatorFn

func TokenAuthenticator

func TokenAuthenticator(token string) AuthenticatorFn

type K8SClient

type K8SClient interface {
	Get(ctx context.Context, name string, options metav1.GetOptions) (*v1beta3.Stack, error)
	Create(ctx context.Context, stack *v1beta3.Stack) (*v1beta3.Stack, error)
	Update(ctx context.Context, stack *v1beta3.Stack) (*v1beta3.Stack, error)
	Delete(ctx context.Context, name string) error
	Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
}