meshnet

Documentation

Index

• type Config
• type Meshnet
  • func New(cfg Config) (*Meshnet, error)
  • func (m *Meshnet) Get(ctx context.Context, pod *mpb.PodQuery) (*mpb.Pod, error)
  • func (m *Meshnet) IsSkipped(ctx context.Context, skip *mpb.SkipQuery) (*mpb.BoolResponse, error)
  • func (m *Meshnet) Serve() error
  • func (m *Meshnet) SetAlive(ctx context.Context, pod *mpb.Pod) (*mpb.BoolResponse, error)
  • func (m *Meshnet) Skip(ctx context.Context, skip *mpb.SkipQuery) (*mpb.BoolResponse, error)
  • func (m *Meshnet) SkipReverse(ctx context.Context, skip *mpb.SkipQuery) (*mpb.BoolResponse, error)
  • func (m *Meshnet) Stop()
  • func (m *Meshnet) Update(ctx context.Context, pod *mpb.RemotePod) (*mpb.BoolResponse, error)

Types

type Config

type Config struct {
	Port     int
	GRPCOpts []grpc.ServerOption
}

type Meshnet

type Meshnet struct {
	mpb.UnimplementedLocalServer
	mpb.UnimplementedRemoteServer
	// contains filtered or unexported fields
}

func New

func New(cfg Config) (*Meshnet, error)

func (*Meshnet) Get

func (m *Meshnet) Get(ctx context.Context, pod *mpb.PodQuery) (*mpb.Pod, error)

func (*Meshnet) IsSkipped

func (m *Meshnet) IsSkipped(ctx context.Context, skip *mpb.SkipQuery) (*mpb.BoolResponse, error)

func (*Meshnet) Serve

func (m *Meshnet) Serve() error

func (*Meshnet) SetAlive

func (m *Meshnet) SetAlive(ctx context.Context, pod *mpb.Pod) (*mpb.BoolResponse, error)

func (*Meshnet) Skip

func (m *Meshnet) Skip(ctx context.Context, skip *mpb.SkipQuery) (*mpb.BoolResponse, error)

func (*Meshnet) SkipReverse

func (m *Meshnet) SkipReverse(ctx context.Context, skip *mpb.SkipQuery) (*mpb.BoolResponse, error)

func (*Meshnet) Stop

func (m *Meshnet) Stop()

func (*Meshnet) Update

func (m *Meshnet) Update(ctx context.Context, pod *mpb.RemotePod) (*mpb.BoolResponse, error)