server

Documentation

Overview

Copyright 2020 Jared Allard

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2020 Jared Allard

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2020 Jared Allard

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2020 Jared Allard

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2020 Jared Allard

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• type Exposer
  • func NewExposer(parentCtx context.Context, k kubernetes.Interface, kconf *rest.Config, ...) (*Exposer, error)
  • func (e *Exposer) Close(namespace, serviceName string) error
  • func (e *Exposer) Start(ports []kube.ResolvedServicePort, namespace, serviceName string) error
  • func (e *Exposer) Wait()
• type GRPCService
  • func NewGRPCService(opts *RunOpts) *GRPCService
  • func (g *GRPCService) CleanupPreviousInstance(ctx context.Context, log logrus.FieldLogger) error
  • func (g *GRPCService) Run(ctx context.Context, log logrus.FieldLogger) error
• type GRPCServiceHandler
  • func NewServiceHandler(ctx context.Context, log logrus.FieldLogger, opts *RunOpts) (*GRPCServiceHandler, error)
  • func (h *GRPCServiceHandler) ExposeService(req *api.ExposeServiceRequest, res api.LocalizerService_ExposeServiceServer) error
  • func (*GRPCServiceHandler) Kill(ctx context.Context, _ *api.Empty) (*api.Empty, error)
  • func (h *GRPCServiceHandler) List(ctx context.Context, req *api.ListRequest) (*api.ListResponse, error)
  • func (h *GRPCServiceHandler) Ping(ctx context.Context, req *api.PingRequest) (*api.PingResponse, error)
  • func (g *GRPCServiceHandler) Stable(ctx context.Context, _ *api.Empty) (*api.StableResponse, error)
  • func (h *GRPCServiceHandler) StopExpose(req *api.StopExposeRequest, res api.LocalizerService_StopExposeServer) error
• type RunOpts

Types

type Exposer

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

func NewExposer

func NewExposer(parentCtx context.Context, k kubernetes.Interface, kconf *rest.Config, log logrus.FieldLogger) (*Exposer, error)

NewExposer creates a service that can maintain multiple expose instances

func (*Exposer) Close

func (e *Exposer) Close(namespace, serviceName string) error

func (*Exposer) Start

func (e *Exposer) Start(ports []kube.ResolvedServicePort, namespace, serviceName string) error

func (*Exposer) Wait

func (e *Exposer) Wait()

Wait waits for all exposes to be shut down

type GRPCService

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

func NewGRPCService

func NewGRPCService(opts *RunOpts) *GRPCService

func (*GRPCService) CleanupPreviousInstance

func (g *GRPCService) CleanupPreviousInstance(ctx context.Context, log logrus.FieldLogger) error

CleanupPreviousInstance attempts to cleanup after a dead localizer instance if a not dead one is found, an error is returned or if it fails to cleanup

func (*GRPCService) Run

func (g *GRPCService) Run(ctx context.Context, log logrus.FieldLogger) error

Run starts a grpc server with the internal server handler

type GRPCServiceHandler

type GRPCServiceHandler struct {
	api.UnimplementedLocalizerServiceServer
	// contains filtered or unexported fields
}

func NewServiceHandler

func NewServiceHandler(ctx context.Context, log logrus.FieldLogger, opts *RunOpts) (*GRPCServiceHandler, error)

func (*GRPCServiceHandler) ExposeService

func (h *GRPCServiceHandler) ExposeService(req *api.ExposeServiceRequest, res api.LocalizerService_ExposeServiceServer) error

func (*GRPCServiceHandler) Kill

func (*GRPCServiceHandler) Kill(ctx context.Context, _ *api.Empty) (*api.Empty, error)

Kill implements the Kill RPC for the localizer gRPC server.

This RPC just kills the current localizer process. Note that it actually waits until after the RPC returns (responds) before killing the process because if it kills it before it attempts to respond, the transport will have been closed already, resulting in a perceived error. Because of this stipulation, this RPC is only BEST EFFORT.

func (*GRPCServiceHandler) List

func (h *GRPCServiceHandler) List(ctx context.Context, req *api.ListRequest) (*api.ListResponse, error)

func (*GRPCServiceHandler) Ping

func (h *GRPCServiceHandler) Ping(ctx context.Context, req *api.PingRequest) (*api.PingResponse, error)

func (*GRPCServiceHandler) Stable

func (g *GRPCServiceHandler) Stable(ctx context.Context, _ *api.Empty) (*api.StableResponse, error)

Stable implements the Stable RPC for the localizer gRPC server.

func (*GRPCServiceHandler) StopExpose

func (h *GRPCServiceHandler) StopExpose(req *api.StopExposeRequest, res api.LocalizerService_StopExposeServer) error

type RunOpts

type RunOpts struct {
	ClusterDomain string
	IPCidr        string
	KubeContext   string
}