engine

package
v0.1.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 12, 2026 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BatchStateKey = batchPrefix + "/state"

Functions

func BatchKey 

func BatchKey(n proto.MerkleBatchNo) string

Types

type AutocertClientConn 

type AutocertClientConn struct {
	shared.BaseClientConn
	// contains filtered or unexported fields
}

func (*AutocertClientConn) DoAutocert 

func (c *AutocertClientConn) DoAutocert(
	ctx context.Context,
	arg infra.DoAutocertArg,
) error

func (*AutocertClientConn) ErrorWrapper 

func (c *AutocertClientConn) ErrorWrapper() func(error) proto.Status

func (*AutocertClientConn) Poke 

func (c *AutocertClientConn) Poke(
	ctx context.Context,
) error

func (*AutocertClientConn) RegisterProtocols 

func (c *AutocertClientConn) RegisterProtocols(m shared.MetaContext, srv *rpc.Server) error

type AutocertServer 

type AutocertServer struct {
	shared.BaseRPCServer
	// contains filtered or unexported fields
}

func (*AutocertServer) CheckDeviceKey 

func (q *AutocertServer) CheckDeviceKey(m shared.MetaContext, uhc shared.UserHostContext, key proto.EntityID) (*proto.Role, error)

func (*AutocertServer) DoOnePollForHost 

func (c *AutocertServer) DoOnePollForHost(m shared.MetaContext) error

func (*AutocertServer) GetConfig 

func (c *AutocertServer) GetConfig() shared.ServerLooperConfigger

func (*AutocertServer) GetLock 

func (c *AutocertServer) GetLock() *shared.Lock

func (*AutocertServer) GetName 

func (c *AutocertServer) GetName() string

func (*AutocertServer) GetPokeCh 

func (c *AutocertServer) GetPokeCh() chan chan<- error

func (*AutocertServer) InitLoop 

func (c *AutocertServer) InitLoop(m shared.MetaContext) error

func (*AutocertServer) IsInternal 

func (q *AutocertServer) IsInternal() bool

func (*AutocertServer) NewClientConn 

func (q *AutocertServer) NewClientConn(xp rpc.Transporter, uhc shared.UserHostContext) shared.ClientConn

func (*AutocertServer) Poke 

func (c *AutocertServer) Poke() error

func (*AutocertServer) PollReadyHosts 

func (c *AutocertServer) PollReadyHosts(m shared.MetaContext) ([]core.ShortHostID, error)

func (*AutocertServer) RequireAuth 

func (q *AutocertServer) RequireAuth() shared.AuthType

func (*AutocertServer) RunBackgroundLoops 

func (s *AutocertServer) RunBackgroundLoops(m shared.MetaContext, shutdownCh chan<- error) error

func (*AutocertServer) ServerType 

func (q *AutocertServer) ServerType() proto.ServerType

func (*AutocertServer) Setup 

func (q *AutocertServer) Setup(m shared.MetaContext) error

func (*AutocertServer) ToRPCServer 

func (s *AutocertServer) ToRPCServer() shared.RPCServer

type BeaconClientConn 

type BeaconClientConn struct {
	shared.BaseClientConn
	// contains filtered or unexported fields
}

func (*BeaconClientConn) BeaconLookup 

func (c *BeaconClientConn) BeaconLookup(ctx context.Context, arg proto.HostID) (proto.TCPAddr, error)

func (*BeaconClientConn) BeaconRegister 

func (c *BeaconClientConn) BeaconRegister(ctx context.Context, arg rem.BeaconRegisterArg) error

func (*BeaconClientConn) ErrorWrapper 

func (c *BeaconClientConn) ErrorWrapper() func(error) proto.Status

func (*BeaconClientConn) RegisterProtocols 

func (c *BeaconClientConn) RegisterProtocols(m shared.MetaContext, srv *rpc.Server) error

type BeaconServer 

type BeaconServer struct {
	shared.BaseRPCServer
}

func (*BeaconServer) CheckDeviceKey 

func (s *BeaconServer) CheckDeviceKey(shared.MetaContext, shared.UserHostContext, proto.EntityID) (*proto.Role, error)

func (*BeaconServer) ConfigureCLIOptions 

func (s *BeaconServer) ConfigureCLIOptions(fs *flag.FlagSet)

func (*BeaconServer) NewClientConn 

func (s *BeaconServer) NewClientConn(xp rpc.Transporter, uhc shared.UserHostContext) shared.ClientConn

func (*BeaconServer) RequireAuth 

func (s *BeaconServer) RequireAuth() shared.AuthType

func (*BeaconServer) ServerType 

func (s *BeaconServer) ServerType() proto.ServerType

func (*BeaconServer) Setup 

func (s *BeaconServer) Setup(m shared.MetaContext) error

func (*BeaconServer) ToRPCServer 

func (s *BeaconServer) ToRPCServer() shared.RPCServer

type InternalCAClientConn 

type InternalCAClientConn struct {
	shared.BaseClientConn
	// contains filtered or unexported fields
}

func (*InternalCAClientConn) ErrorWrapper 

func (c *InternalCAClientConn) ErrorWrapper() func(error) proto.Status

func (*InternalCAClientConn) GetClientCertChainForService 

func (c *InternalCAClientConn) GetClientCertChainForService(ctx context.Context, arg infra.GetClientCertChainForServiceArg) ([][]byte, error)

func (*InternalCAClientConn) RegisterProtocols 

func (c *InternalCAClientConn) RegisterProtocols(m shared.MetaContext, srv *rpc.Server) error

type InternalCAServer 

type InternalCAServer struct {
	shared.BaseRPCServer
}

func (*InternalCAServer) CheckDeviceKey 

func (s *InternalCAServer) CheckDeviceKey(m shared.MetaContext, uhc shared.UserHostContext, key proto.EntityID) (*proto.Role, error)

func (*InternalCAServer) NewClientConn 

func (b *InternalCAServer) NewClientConn(xp rpc.Transporter, uhc shared.UserHostContext) shared.ClientConn

func (*InternalCAServer) RequireAuth 

func (s *InternalCAServer) RequireAuth() shared.AuthType

func (*InternalCAServer) ServerType 

func (s *InternalCAServer) ServerType() proto.ServerType

func (*InternalCAServer) ToRPCServer 

func (s *InternalCAServer) ToRPCServer() shared.RPCServer

type MerkleBatcherClientConn 

type MerkleBatcherClientConn struct {
	shared.BaseClientConn
	// contains filtered or unexported fields
}

func (*MerkleBatcherClientConn) ErrorWrapper 

func (c *MerkleBatcherClientConn) ErrorWrapper() func(error) proto.Status

func (*MerkleBatcherClientConn) Poke 

func (c *MerkleBatcherClientConn) Poke(ctx context.Context) error

func (*MerkleBatcherClientConn) RegisterProtocols 

func (c *MerkleBatcherClientConn) RegisterProtocols(m shared.MetaContext, srv *rpc.Server) error

type MerkleBatcherServer 

type MerkleBatcherServer struct {
	MerklePipelineBaseServer
	// contains filtered or unexported fields
}

func NewMerkleBatcherServer 

func NewMerkleBatcherServer() *MerkleBatcherServer

func (*MerkleBatcherServer) ConfigureCLIOptions 

func (b *MerkleBatcherServer) ConfigureCLIOptions(fs *flag.FlagSet)

func (*MerkleBatcherServer) NewClientConn 

func (b *MerkleBatcherServer) NewClientConn(xp rpc.Transporter, uhc shared.UserHostContext) shared.ClientConn

func (*MerkleBatcherServer) Setup 

func (b *MerkleBatcherServer) Setup(m shared.MetaContext) error

func (*MerkleBatcherServer) ToRPCServer 

func (s *MerkleBatcherServer) ToRPCServer() shared.RPCServer

type MerkleBatcherVHostState 

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

type MerkleBuilderClientConn 

type MerkleBuilderClientConn struct {
	shared.BaseClientConn
	// contains filtered or unexported fields
}

func (*MerkleBuilderClientConn) ErrorWrapper 

func (c *MerkleBuilderClientConn) ErrorWrapper() func(error) proto.Status

func (*MerkleBuilderClientConn) Poke 

func (c *MerkleBuilderClientConn) Poke(ctx context.Context) error

func (*MerkleBuilderClientConn) RegisterProtocols 

func (c *MerkleBuilderClientConn) RegisterProtocols(m shared.MetaContext, srv *rpc.Server) error

type MerkleBuilderServer 

type MerkleBuilderServer struct {
	MerklePipelineBaseServer
}

func NewMerkleBuilderServer 

func NewMerkleBuilderServer() *MerkleBuilderServer

func (*MerkleBuilderServer) ConfigureCLIOptions 

func (b *MerkleBuilderServer) ConfigureCLIOptions(fs *flag.FlagSet)

func (*MerkleBuilderServer) NewClientConn 

func (b *MerkleBuilderServer) NewClientConn(xp rpc.Transporter, uhc shared.UserHostContext) shared.ClientConn

func (*MerkleBuilderServer) Setup 

func (b *MerkleBuilderServer) Setup(m shared.MetaContext) error

func (*MerkleBuilderServer) ToRPCServer 

func (s *MerkleBuilderServer) ToRPCServer() shared.RPCServer

type MerklePipelineBaseServer 

type MerklePipelineBaseServer struct {
	shared.BaseRPCServer
	// contains filtered or unexported fields
}

func (*MerklePipelineBaseServer) CheckDeviceKey 

func (s *MerklePipelineBaseServer) CheckDeviceKey(m shared.MetaContext, uhc shared.UserHostContext, key proto.EntityID) (*proto.Role, error)

func (*MerklePipelineBaseServer) DoOnePollForHost 

func (s *MerklePipelineBaseServer) DoOnePollForHost(m shared.MetaContext) error

func (*MerklePipelineBaseServer) GetConfig 

func (s *MerklePipelineBaseServer) GetConfig() shared.ServerLooperConfigger

func (*MerklePipelineBaseServer) GetLock 

func (s *MerklePipelineBaseServer) GetLock() *shared.Lock

func (*MerklePipelineBaseServer) GetName 

func (s *MerklePipelineBaseServer) GetName() string

func (*MerklePipelineBaseServer) GetPokeCh 

func (s *MerklePipelineBaseServer) GetPokeCh() chan chan<- error

func (*MerklePipelineBaseServer) InitLoop 

func (s *MerklePipelineBaseServer) InitLoop(m shared.MetaContext) error

func (*MerklePipelineBaseServer) Poke 

func (s *MerklePipelineBaseServer) Poke(ctx context.Context) error

func (*MerklePipelineBaseServer) PollReadyHosts 

func (s *MerklePipelineBaseServer) PollReadyHosts(
	m shared.MetaContext,
) (
	[]core.ShortHostID,
	error,
)

func (*MerklePipelineBaseServer) RequireAuth 

func (s *MerklePipelineBaseServer) RequireAuth() shared.AuthType

func (*MerklePipelineBaseServer) RunBackgroundLoops 

func (s *MerklePipelineBaseServer) RunBackgroundLoops(m shared.MetaContext, shutdownCh chan<- error) error

func (*MerklePipelineBaseServer) ServerType 

func (s *MerklePipelineBaseServer) ServerType() proto.ServerType

func (*MerklePipelineBaseServer) Setup 

func (b *MerklePipelineBaseServer) Setup(m shared.MetaContext) error

func (*MerklePipelineBaseServer) Shutdown 

func (s *MerklePipelineBaseServer) Shutdown(m shared.MetaContext) error

type MerklePipelineSubclass 

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

type MerkleQueryClientConn 

type MerkleQueryClientConn struct {
	shared.BaseClientConn
	// contains filtered or unexported fields
}

func (*MerkleQueryClientConn) CheckKeyExists 

func (c *MerkleQueryClientConn) CheckKeyExists(ctx context.Context, arg rem.CheckKeyExistsArg) (rem.MerkleExistsRes, error)

func (*MerkleQueryClientConn) ConfirmRoot 

func (c *MerkleQueryClientConn) ConfirmRoot(ctx context.Context, arg rem.ConfirmRootArg) error

func (*MerkleQueryClientConn) ErrorWrapper 

func (c *MerkleQueryClientConn) ErrorWrapper() func(error) proto.Status

func (*MerkleQueryClientConn) GetCurrentRoot 

func (c *MerkleQueryClientConn) GetCurrentRoot(ctx context.Context, hid *proto.HostID) (proto.MerkleRoot, error)

func (*MerkleQueryClientConn) GetCurrentRootHash 

func (c *MerkleQueryClientConn) GetCurrentRootHash(ctx context.Context, hid *proto.HostID) (proto.TreeRoot, error)

func (*MerkleQueryClientConn) GetCurrentRootSigned 

func (c *MerkleQueryClientConn) GetCurrentRootSigned(ctx context.Context, hid *proto.HostID) (proto.SignedMerkleRoot, error)

func (*MerkleQueryClientConn) GetCurrentRootSignedEpno 

func (c *MerkleQueryClientConn) GetCurrentRootSignedEpno(ctx context.Context, hid *proto.HostID) (proto.MerkleEpno, error)

func (*MerkleQueryClientConn) GetHistoricalRoots 

func (c *MerkleQueryClientConn) GetHistoricalRoots(ctx context.Context, arg rem.GetHistoricalRootsArg) (rem.GetHistoricalRootsRes, error)

func (*MerkleQueryClientConn) Lookup 

func (c *MerkleQueryClientConn) Lookup(ctx context.Context, arg rem.MerkleLookupArg) (proto.MerklePathCompressed, error)

func (*MerkleQueryClientConn) MLookup 

func (c *MerkleQueryClientConn) MLookup(ctx context.Context, arg rem.MerkleMLookupArg) (proto.MerklePathsCompressed, error)

func (*MerkleQueryClientConn) Probe 

func (c *MerkleQueryClientConn) Probe(ctx context.Context, arg rem.ProbeArg) (rem.ProbeRes, error)

func (*MerkleQueryClientConn) RegisterProtocols 

func (c *MerkleQueryClientConn) RegisterProtocols(m shared.MetaContext, srv *rpc.Server) error

func (*MerkleQueryClientConn) Reset 

func (c *MerkleQueryClientConn) Reset(ctx context.Context) error

Used mainly for testing

func (*MerkleQueryClientConn) SelectVHost 

func (m *MerkleQueryClientConn) SelectVHost(ctx context.Context, hid proto.HostID) error

type MerkleQueryServer 

type MerkleQueryServer struct {
	shared.BaseRPCServer
	// contains filtered or unexported fields
}

func (*MerkleQueryServer) CheckDeviceKey 

func (s *MerkleQueryServer) CheckDeviceKey(m shared.MetaContext, uhc shared.UserHostContext, key proto.EntityID) (*proto.Role, error)

func (*MerkleQueryServer) NewClientConn 

func (b *MerkleQueryServer) NewClientConn(xp rpc.Transporter, uhc shared.UserHostContext) shared.ClientConn

func (*MerkleQueryServer) RequireAuth 

func (s *MerkleQueryServer) RequireAuth() shared.AuthType

func (*MerkleQueryServer) ServerType 

func (s *MerkleQueryServer) ServerType() proto.ServerType

func (*MerkleQueryServer) Setup 

func (s *MerkleQueryServer) Setup(m shared.MetaContext) error

func (*MerkleQueryServer) ToRPCServer 

func (s *MerkleQueryServer) ToRPCServer() shared.RPCServer

type MerkleSignerClientConn 

type MerkleSignerClientConn struct {
	shared.BaseClientConn
	// contains filtered or unexported fields
}

func (*MerkleSignerClientConn) ErrorWrapper 

func (c *MerkleSignerClientConn) ErrorWrapper() func(error) proto.Status

func (*MerkleSignerClientConn) Poke 

func (c *MerkleSignerClientConn) Poke(ctx context.Context) error

func (*MerkleSignerClientConn) RegisterProtocols 

func (c *MerkleSignerClientConn) RegisterProtocols(m shared.MetaContext, srv *rpc.Server) error

type MerkleSignerServer 

type MerkleSignerServer struct {
	MerklePipelineBaseServer
	// contains filtered or unexported fields
}

func NewMerkleSignerServer 

func NewMerkleSignerServer() *MerkleSignerServer

func (*MerkleSignerServer) ConfigureCLIOptions 

func (b *MerkleSignerServer) ConfigureCLIOptions(fs *flag.FlagSet)

func (*MerkleSignerServer) NewClientConn 

func (b *MerkleSignerServer) NewClientConn(xp rpc.Transporter, uhc shared.UserHostContext) shared.ClientConn

func (*MerkleSignerServer) Setup 

func (b *MerkleSignerServer) Setup(m shared.MetaContext) error

func (*MerkleSignerServer) ToRPCServer 

func (s *MerkleSignerServer) ToRPCServer() shared.RPCServer

type MerkleSignerVHostState 

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

type ProbeClientConn 

type ProbeClientConn struct {
	shared.BaseClientConn
	// contains filtered or unexported fields
}

func (*ProbeClientConn) ErrorWrapper 

func (c *ProbeClientConn) ErrorWrapper() func(error) proto.Status

func (*ProbeClientConn) Probe 

func (c *ProbeClientConn) Probe(ctx context.Context, arg rem.ProbeArg) (rem.ProbeRes, error)

func (*ProbeClientConn) RegisterProtocols 

func (c *ProbeClientConn) RegisterProtocols(m shared.MetaContext, srv *rpc.Server) error

type ProbeServer 

type ProbeServer struct {
	shared.BaseRPCServer
}

func (*ProbeServer) CheckDeviceKey 

func (s *ProbeServer) CheckDeviceKey(shared.MetaContext, shared.UserHostContext, proto.EntityID) (*proto.Role, error)

func (*ProbeServer) ConfigureCLIOptions 

func (s *ProbeServer) ConfigureCLIOptions(fs *flag.FlagSet)

func (*ProbeServer) NewClientConn 

func (s *ProbeServer) NewClientConn(xp rpc.Transporter, uhc shared.UserHostContext) shared.ClientConn

func (*ProbeServer) RequireAuth 

func (s *ProbeServer) RequireAuth() shared.AuthType

func (*ProbeServer) ServerType 

func (s *ProbeServer) ServerType() proto.ServerType

func (*ProbeServer) Setup 

func (s *ProbeServer) Setup(m shared.MetaContext) error

func (*ProbeServer) ToRPCServer 

func (s *ProbeServer) ToRPCServer() shared.RPCServer

type QueueClientConn 

type QueueClientConn struct {
	shared.BaseClientConn
	// contains filtered or unexported fields
}

func (*QueueClientConn) Dequeue 

func (c *QueueClientConn) Dequeue(ctx context.Context, arg infra.DequeueArg) ([]byte, error)

func (*QueueClientConn) Enqueue 

func (c *QueueClientConn) Enqueue(ctx context.Context, arg infra.EnqueueArg) error

func (*QueueClientConn) ErrorWrapper 

func (c *QueueClientConn) ErrorWrapper() func(error) proto.Status

func (*QueueClientConn) RegisterProtocols 

func (c *QueueClientConn) RegisterProtocols(m shared.MetaContext, srv *rpc.Server) error

type QueueServer 

type QueueServer struct {
	shared.BaseRPCServer
	// contains filtered or unexported fields
}

func (*QueueServer) CheckDeviceKey 

func (s *QueueServer) CheckDeviceKey(m shared.MetaContext, uhc shared.UserHostContext, key proto.EntityID) (*proto.Role, error)

func (*QueueServer) IsInternal 

func (s *QueueServer) IsInternal() bool

func (*QueueServer) NewClientConn 

func (b *QueueServer) NewClientConn(xp rpc.Transporter, uhc shared.UserHostContext) shared.ClientConn

func (*QueueServer) RequireAuth 

func (s *QueueServer) RequireAuth() shared.AuthType

func (*QueueServer) ServerType 

func (s *QueueServer) ServerType() proto.ServerType

func (*QueueServer) Setup 

func (s *QueueServer) Setup(m shared.MetaContext) error

func (*QueueServer) ToRPCServer 

func (s *QueueServer) ToRPCServer() shared.RPCServer

type QuotaClientConn 

type QuotaClientConn struct {
	shared.BaseClientConn
	// contains filtered or unexported fields
}

func (*QuotaClientConn) AssignQuotaMaster 

func (c *QuotaClientConn) AssignQuotaMaster(ctx context.Context, arg infra.AssignQuotaMasterArg) error

func (*QuotaClientConn) CancelPlan 

func (c *QuotaClientConn) CancelPlan(
	ctx context.Context,
	fqu proto.FQUser,
) (
	proto.CancelID,
	error,
)

func (*QuotaClientConn) ErrorWrapper 

func (c *QuotaClientConn) ErrorWrapper() func(error) proto.Status

func (*QuotaClientConn) MakePlan 

func (c *QuotaClientConn) MakePlan(
	ctx context.Context,
	arg infra.MakePlanArg,
) (
	infra.Plan,
	error,
)

func (*QuotaClientConn) Poke 

func (c *QuotaClientConn) Poke(ctx context.Context) error

func (*QuotaClientConn) RegisterProtocols 

func (c *QuotaClientConn) RegisterProtocols(m shared.MetaContext, srv *rpc.Server) error

func (*QuotaClientConn) SetPlan 

func (c *QuotaClientConn) SetPlan(
	ctx context.Context,
	arg infra.SetPlanArg,
) (
	proto.CancelID,
	error,
)

func (*QuotaClientConn) TestBumpUsage 

func (c *QuotaClientConn) TestBumpUsage(ctx context.Context, arg infra.TestBumpUsageArg) error

func (*QuotaClientConn) TestSetConfig 

func (c *QuotaClientConn) TestSetConfig(ctx context.Context, cfg infra.QuotaConfig) error

func (*QuotaClientConn) TestUnsetConfig 

func (c *QuotaClientConn) TestUnsetConfig(ctx context.Context) error

func (*QuotaClientConn) UnassignQuotaMaster 

func (c *QuotaClientConn) UnassignQuotaMaster(ctx context.Context, arg infra.UnassignQuotaMasterArg) error

type QuotaServer 

type QuotaServer struct {
	shared.BaseRPCServer
	// contains filtered or unexported fields
}

func (*QuotaServer) CheckDeviceKey 

func (q *QuotaServer) CheckDeviceKey(m shared.MetaContext, uhc shared.UserHostContext, key proto.EntityID) (*proto.Role, error)

func (*QuotaServer) DoOnePollForHost 

func (c *QuotaServer) DoOnePollForHost(m shared.MetaContext) error

func (*QuotaServer) DoResurrection 

func (s *QuotaServer) DoResurrection() bool

func (*QuotaServer) GetConfig 

func (c *QuotaServer) GetConfig() shared.ServerLooperConfigger

func (*QuotaServer) GetDelay 

func (c *QuotaServer) GetDelay() time.Duration

func (*QuotaServer) GetLock 

func (c *QuotaServer) GetLock() *shared.Lock

func (*QuotaServer) GetName 

func (c *QuotaServer) GetName() string

func (*QuotaServer) GetNoPlanMaxTeams 

func (s *QuotaServer) GetNoPlanMaxTeams() int

func (*QuotaServer) GetPokeCh 

func (c *QuotaServer) GetPokeCh() chan chan<- error

func (*QuotaServer) InitLoop 

func (c *QuotaServer) InitLoop(m shared.MetaContext) error

func (*QuotaServer) IsInternal 

func (q *QuotaServer) IsInternal() bool

func (*QuotaServer) NewClientConn 

func (q *QuotaServer) NewClientConn(xp rpc.Transporter, uhc shared.UserHostContext) shared.ClientConn

func (*QuotaServer) Poke 

func (s *QuotaServer) Poke() error

func (*QuotaServer) PollReadyHosts 

func (c *QuotaServer) PollReadyHosts(m shared.MetaContext) ([]core.ShortHostID, error)

func (*QuotaServer) RequireAuth 

func (q *QuotaServer) RequireAuth() shared.AuthType

func (*QuotaServer) RunBackgroundLoops 

func (s *QuotaServer) RunBackgroundLoops(m shared.MetaContext, shutdownCh chan<- error) error

func (*QuotaServer) ServerType 

func (q *QuotaServer) ServerType() proto.ServerType

func (*QuotaServer) SetTestParams 

func (q *QuotaServer) SetTestParams(tst *infra.QuotaConfig) error

func (*QuotaServer) Setup 

func (q *QuotaServer) Setup(m shared.MetaContext) error

func (*QuotaServer) ToRPCServer 

func (s *QuotaServer) ToRPCServer() shared.RPCServer

type RegClientConn 

type RegClientConn struct {
	shared.BaseClientConn
	// contains filtered or unexported fields
}

func (*RegClientConn) AcceptInviteRemote 

func (r *RegClientConn) AcceptInviteRemote(
	ctx context.Context,
	arg rem.AcceptInviteRemoteArg,
) (proto.TeamRSVPRemote, error)

func (*RegClientConn) ActivateTeamVOBearerToken 

func (r *RegClientConn) ActivateTeamVOBearerToken(
	ctx context.Context,
	arg rem.ActivateTeamVOBearerTokenArg,
) (
	rem.ActivatedVOBearerToken,
	error,
)

func (*RegClientConn) CheckArgHeader 

func (c *RegClientConn) CheckArgHeader(ctx context.Context, arg proto.Header) error

func (*RegClientConn) CheckInviteCode 

func (c *RegClientConn) CheckInviteCode(ctx context.Context, ic rem.InviteCode) error

func (*RegClientConn) CheckNameExists 

func (c *RegClientConn) CheckNameExists(ctx context.Context, arg proto.Name) error

func (*RegClientConn) CheckTeamVOBearerToken 

func (u *RegClientConn) CheckTeamVOBearerToken(
	ctx context.Context,
	arg rem.CheckTeamVOBearerTokenArg,
) (
	proto.TeamID,
	error,
)

func (*RegClientConn) ErrorWrapper 

func (c *RegClientConn) ErrorWrapper() func(error) proto.Status

func (*RegClientConn) GetClientCertChain 

func (c *RegClientConn) GetClientCertChain(ctx context.Context, arg rem.GetClientCertChainArg) ([][]byte, error)

func (*RegClientConn) GetClientVersionInfo added in v0.0.19 

func (c *RegClientConn) GetClientVersionInfo(
	ctx context.Context,
	arg proto.ClientVersionExt,
) (
	proto.ServerClientVersionInfo,
	error,
)

func (*RegClientConn) GetHostID 

func (c *RegClientConn) GetHostID(ctx context.Context) (proto.HostID, error)

func (*RegClientConn) GetLoginChallenge 

func (r *RegClientConn) GetLoginChallenge(ctx context.Context, uid proto.UID) (rem.Challenge, error)

func (*RegClientConn) GetServerConfig 

func (c *RegClientConn) GetServerConfig(ctx context.Context) (proto.RegServerConfig, error)

func (*RegClientConn) GetSubkeyBoxChallenge 

func (r *RegClientConn) GetSubkeyBoxChallenge(ctx context.Context, parent proto.EntityID) (rem.Challenge, error)

func (*RegClientConn) GetTeamVOBearerTokenChallenge 

func (r *RegClientConn) GetTeamVOBearerTokenChallenge(
	ctx context.Context,
	req rem.TeamVOBearerTokenReq,
) (
	rem.TeamVOBearerTokenChallenge,
	error,
)

func (*RegClientConn) GetUIDLookupChallege 

func (r *RegClientConn) GetUIDLookupChallege(ctx context.Context, eid proto.EntityID) (rem.Challenge, error)

func (*RegClientConn) GetVHostMgmtHost 

func (c *RegClientConn) GetVHostMgmtHost(ctx context.Context) (proto.TCPAddr, error)

func (*RegClientConn) InitOAuth2Session 

func (c *RegClientConn) InitOAuth2Session(ctx context.Context, arg rem.InitOAuth2SessionArg) (proto.URLString, error)

func (*RegClientConn) JoinWaitList 

func (c *RegClientConn) JoinWaitList(ctx context.Context, em proto.Email) (proto.WaitListID, error)

func (*RegClientConn) LoadRemovalForMember 

func (u *RegClientConn) LoadRemovalForMember(
	ctx context.Context,
	arg rem.LoadRemovalForMemberArg,
) (
	rem.TeamRemovalAndKeyBox,
	error,
)

func (*RegClientConn) LoadSubkeyBox 

func (c *RegClientConn) LoadSubkeyBox(ctx context.Context, arg rem.LoadSubkeyBoxArg) (proto.Box, error)

func (*RegClientConn) LoadTeamChain 

func (r *RegClientConn) LoadTeamChain(
	ctx context.Context,
	arg rem.LoadTeamChainArg,
) (
	rem.TeamChain,
	error,
)

func (*RegClientConn) LoadTeamMembershipChain 

func (r *RegClientConn) LoadTeamMembershipChain(
	ctx context.Context,
	arg rem.LoadTeamMembershipChainArg,
) (
	rem.GenericChain,
	error,
)

func (*RegClientConn) LoadTeamRemoteViewTokens 

func (u *RegClientConn) LoadTeamRemoteViewTokens(
	ctx context.Context,
	arg rem.LoadTeamRemoteViewTokensArg,
) (
	rem.TeamRemoteViewTokenSet,
	error,
)

func (*RegClientConn) LoadUserChain 

func (c *RegClientConn) LoadUserChain(ctx context.Context, arg rem.LoadUserChainArg) (rem.UserChain, error)

func (*RegClientConn) LogSendInit added in v0.1.0 

func (c *RegClientConn) LogSendInit(ctx context.Context) (lib.LogSendID, error)

func (*RegClientConn) LogSendInitFile added in v0.1.0 

func (c *RegClientConn) LogSendInitFile(
	ctx context.Context,
	arg rem.LogSendInitFileArg,
) error

func (*RegClientConn) LogSendUploadBlock added in v0.1.0 

func (c *RegClientConn) LogSendUploadBlock(
	ctx context.Context,
	arg rem.LogSendUploadBlockArg,
) error

func (*RegClientConn) Login 

func (c *RegClientConn) Login(ctx context.Context, arg rem.LoginArg) (rem.LoginRes, error)

func (*RegClientConn) LookupTeamCertByHash 

func (r *RegClientConn) LookupTeamCertByHash(
	ctx context.Context,
	i proto.TeamInvite,
) (
	rem.TeamCertAndMetadata,
	error,
)

func (*RegClientConn) LookupUIDByDevice 

func (c *RegClientConn) LookupUIDByDevice(ctx context.Context, arg rem.LookupUIDByDeviceArg) (proto.LookupUserRes, error)

func (*RegClientConn) MakeResHeader 

func (c *RegClientConn) MakeResHeader() proto.Header

func (*RegClientConn) PollOAuth2SessionCompletion 

func (c *RegClientConn) PollOAuth2SessionCompletion(
	ctx context.Context,
	arg rem.PollOAuth2SessionCompletionArg,
) (rem.OAuth2PollRes, error)

func (*RegClientConn) Probe 

func (c *RegClientConn) Probe(ctx context.Context, arg rem.ProbeArg) (rem.ProbeRes, error)

func (*RegClientConn) ProbeKeyExists 

func (c *RegClientConn) ProbeKeyExists(
	ctx context.Context,
	arg rem.ProbeKeyExistsArg,
) error

func (*RegClientConn) Receive 

func (c *RegClientConn) Receive(ctx context.Context, arg rem.ReceiveArg) (rem.KexWrapperMsg, error)

func (*RegClientConn) RegisterProtocols 

func (c *RegClientConn) RegisterProtocols(m shared.MetaContext, srv *rpc.Server) error

func (*RegClientConn) ReserveUsername 

func (c *RegClientConn) ReserveUsername(ctx context.Context, nm proto.Name) (rem.ReserveNameRes, error)

func (*RegClientConn) ResolveUsername 

func (c *RegClientConn) ResolveUsername(
	ctx context.Context,
	arg rem.ResolveUsernameArg,
) (
	proto.UID,
	error,
)

func (*RegClientConn) SelectVHost 

func (c *RegClientConn) SelectVHost(ctx context.Context, hid proto.HostID) error

func (*RegClientConn) Send 

func (c *RegClientConn) Send(ctx context.Context, arg rem.SendArg) error

func (*RegClientConn) Signup 

func (c *RegClientConn) Signup(ctx context.Context, arg rem.SignupArg) error

func (*RegClientConn) SsoLogin 

func (c *RegClientConn) SsoLogin(ctx context.Context, arg rem.SsoLoginArg) error

func (*RegClientConn) StretchVersion 

func (c *RegClientConn) StretchVersion(ctx context.Context) (proto.StretchVersion, error)

type RegServer 

type RegServer struct {
	shared.BaseRPCServer
	// contains filtered or unexported fields
}

func (*RegServer) CheckDeviceKey 

func (s *RegServer) CheckDeviceKey(m shared.MetaContext, uhc shared.UserHostContext, key proto.EntityID) (*proto.Role, error)

func (*RegServer) ConfigureCLIOptions 

func (s *RegServer) ConfigureCLIOptions(fs *flag.FlagSet)

func (*RegServer) NewClientConn 

func (s *RegServer) NewClientConn(xp rpc.Transporter, uhc shared.UserHostContext) shared.ClientConn

func (*RegServer) RequireAuth 

func (s *RegServer) RequireAuth() shared.AuthType

func (*RegServer) ServerType 

func (s *RegServer) ServerType() proto.ServerType

func (*RegServer) SetTestTimeTravel 

func (s *RegServer) SetTestTimeTravel(t time.Duration)

func (*RegServer) Setup 

func (s *RegServer) Setup(m shared.MetaContext) error

func (*RegServer) TestTimeTravel 

func (s *RegServer) TestTimeTravel() time.Duration

func (*RegServer) ToRPCServer 

func (s *RegServer) ToRPCServer() shared.RPCServer

type UserClientConn 

type UserClientConn struct {
	shared.BaseClientConn
	// contains filtered or unexported fields
}

func (*UserClientConn) AcceptInviteLocal 

func (u *UserClientConn) AcceptInviteLocal(
	ctx context.Context,
	arg rem.AcceptInviteLocalArg,
) (
	proto.TeamRSVPLocal,
	error,
)

func (*UserClientConn) ActivateTeamBearerToken 

func (u *UserClientConn) ActivateTeamBearerToken(
	ctx context.Context,
	arg rem.ActivateTeamBearerTokenArg,
) error

func (*UserClientConn) ActivateTeamVOBearerToken 

func (u *UserClientConn) ActivateTeamVOBearerToken(
	ctx context.Context,
	arg rem.ActivateTeamVOBearerTokenArg,
) (
	rem.ActivatedVOBearerToken,
	error,
)

func (*UserClientConn) AssertPQKeyNotInUse 

func (c *UserClientConn) AssertPQKeyNotInUse(
	ctx context.Context,
	arg proto.YubiPQKeyID,
) error

func (*UserClientConn) ChangePassphrase 

func (c *UserClientConn) ChangePassphrase(ctx context.Context, arg rem.ChangePassphraseArg) error

func (*UserClientConn) ChangeUsername 

func (c *UserClientConn) ChangeUsername(ctx context.Context, arg rem.ChangeUsernameArg) error

func (*UserClientConn) CheckTeamBearerToken 

func (u *UserClientConn) CheckTeamBearerToken(
	ctx context.Context,
	arg rem.TeamBearerToken,
) (
	proto.TeamID,
	error,
)

func (*UserClientConn) CheckTeamVOBearerToken 

func (u *UserClientConn) CheckTeamVOBearerToken(
	ctx context.Context,
	arg rem.CheckTeamVOBearerTokenArg,
) (
	proto.TeamID,
	error,
)

func (*UserClientConn) CheckURL 

func (c *UserClientConn) CheckURL(
	ctx context.Context,
	arg proto.URLString,
) error

func (*UserClientConn) ClearDeviceNag 

func (c *UserClientConn) ClearDeviceNag(
	ctx context.Context,
	val bool,
) error

func (*UserClientConn) CreateTeam 

func (c *UserClientConn) CreateTeam(
	ctx context.Context,
	arg rem.CreateTeamArg,
) error

func (*UserClientConn) EditTeam 

func (c *UserClientConn) EditTeam(
	ctx context.Context,
	arg rem.EditTeamArg,
) (
	rem.EditTeamRes,
	error,
)

func (*UserClientConn) ErrorWrapper 

func (c *UserClientConn) ErrorWrapper() func(error) proto.Status

func (*UserClientConn) GetAllYubiManagementKeys 

func (c *UserClientConn) GetAllYubiManagementKeys(
	ctx context.Context,
) (
	[]rem.YubiEncryptedManagementKey,
	error,
)

func (*UserClientConn) GetCurrentTeamCerts 

func (u *UserClientConn) GetCurrentTeamCerts(
	ctx context.Context,
	arg rem.TeamBearerToken,
) (
	[]rem.TeamCert,
	error,
)

func (*UserClientConn) GetDeviceNag 

func (c *UserClientConn) GetDeviceNag(
	ctx context.Context,
) (
	proto.DeviceNagInfo,
	error,
)

func (*UserClientConn) GetHostConfig 

func (c *UserClientConn) GetHostConfig(
	ctx context.Context,
) (
	proto.HostConfig,
	error,
)

func (*UserClientConn) GetPUKForRole 

func (c *UserClientConn) GetPUKForRole(ctx context.Context, arg rem.GetPUKForRoleArg) (proto.SharedKeyParcel, error)

func (*UserClientConn) GetPpeParcel 

func (c *UserClientConn) GetPpeParcel(
	ctx context.Context,
) (
	proto.PpeParcel,
	error,
)

func (*UserClientConn) GetSalt 

func (c *UserClientConn) GetSalt(ctx context.Context) (proto.PassphraseSalt, error)

func (*UserClientConn) GetServerConfig added in v0.0.20 

func (u *UserClientConn) GetServerConfig(
	ctx context.Context,
) (
	proto.RegServerConfig,
	error,
)

func (*UserClientConn) GetTeamConfig added in v0.0.19 

func (u *UserClientConn) GetTeamConfig(ctx context.Context) (rem.TeamConfig, error)

func (*UserClientConn) GetTeamListServerTrust 

func (c *UserClientConn) GetTeamListServerTrust(
	ctx context.Context,
) (
	rem.LocalTeamList,
	error,
)

func (*UserClientConn) GetTeamVOBearerTokenChallenge 

func (r *UserClientConn) GetTeamVOBearerTokenChallenge(
	ctx context.Context,
	req rem.TeamVOBearerTokenReq,
) (
	rem.TeamVOBearerTokenChallenge,
	error,
)

func (*UserClientConn) GetTreeLocation 

func (c *UserClientConn) GetTreeLocation(ctx context.Context, seqno proto.Seqno) (proto.TreeLocation, error)

func (*UserClientConn) GetYubiManagementKey 

func (c *UserClientConn) GetYubiManagementKey(
	ctx context.Context,
	yid proto.YubiID,
) (
	rem.YubiEncryptedManagementKey,
	error,
)

func (*UserClientConn) GrantLocalViewPermissionForTeam 

func (u *UserClientConn) GrantLocalViewPermissionForTeam(
	ctx context.Context,
	arg rem.GrantLocalViewPermissionForTeamArg,
) (
	proto.PermissionToken,
	error,
)

func (*UserClientConn) GrantLocalViewPermissionForUser 

func (c *UserClientConn) GrantLocalViewPermissionForUser(
	ctx context.Context,
	arg rem.GrantLocalViewPermissionPayload,
) (
	proto.PermissionToken,
	error,
)

func (*UserClientConn) GrantRemoteViewPermissionForTeam 

func (u *UserClientConn) GrantRemoteViewPermissionForTeam(
	ctx context.Context,
	arg rem.GrantRemoteViewPermissionForTeamArg,
) (
	proto.PermissionToken,
	error,
)

func (*UserClientConn) GrantRemoteViewPermissionForUser 

func (c *UserClientConn) GrantRemoteViewPermissionForUser(
	ctx context.Context,
	arg rem.GrantRemoteViewPermissionPayload,
) (
	proto.PermissionToken,
	error,
)

func (*UserClientConn) LoadGenericChain 

func (c *UserClientConn) LoadGenericChain(
	ctx context.Context,
	arg rem.LoadGenericChainArg,
) (
	rem.GenericChain,
	error,
)

func (*UserClientConn) LoadRemovalForMember 

func (u *UserClientConn) LoadRemovalForMember(
	ctx context.Context,
	arg rem.LoadRemovalForMemberArg,
) (
	rem.TeamRemovalAndKeyBox,
	error,
)

func (*UserClientConn) LoadRemovalKeyBoxForTeamAdmin 

func (u *UserClientConn) LoadRemovalKeyBoxForTeamAdmin(
	ctx context.Context,
	arg rem.LoadRemovalKeyBoxForTeamAdminArg,
) (
	proto.TeamRemovalKeyBox,
	error,
)

func (*UserClientConn) LoadTeamChain 

func (u *UserClientConn) LoadTeamChain(
	ctx context.Context,
	arg rem.LoadTeamChainArg,
) (
	rem.TeamChain,
	error,
)

func (*UserClientConn) LoadTeamMembershipChain 

func (u *UserClientConn) LoadTeamMembershipChain(
	ctx context.Context,
	arg rem.LoadTeamMembershipChainArg,
) (
	rem.GenericChain,
	error,
)

func (*UserClientConn) LoadTeamRawInbox 

func (u *UserClientConn) LoadTeamRawInbox(
	ctx context.Context,
	arg rem.LoadTeamRawInboxArg,
) (
	rem.TeamRawInbox,
	error,
)

func (*UserClientConn) LoadTeamRemoteJoinReq 

func (u *UserClientConn) LoadTeamRemoteJoinReq(
	ctx context.Context,
	arg rem.LoadTeamRemoteJoinReqArg,
) (
	rem.TeamRemoteJoinReq,
	error,
)

func (*UserClientConn) LoadTeamRemoteViewTokens 

func (u *UserClientConn) LoadTeamRemoteViewTokens(
	ctx context.Context,
	arg rem.LoadTeamRemoteViewTokensArg,
) (
	rem.TeamRemoteViewTokenSet,
	error,
)

func (*UserClientConn) LoadUserChain 

func (c *UserClientConn) LoadUserChain(ctx context.Context, arg rem.LoadUserChainArg) (rem.UserChain, error)

func (*UserClientConn) LogSendInit added in v0.1.0 

func (c *UserClientConn) LogSendInit(ctx context.Context) (lib.LogSendID, error)

func (*UserClientConn) LogSendInitFile added in v0.1.0 

func (c *UserClientConn) LogSendInitFile(
	ctx context.Context,
	arg rem.LogSendInitFileArg,
) error

func (*UserClientConn) LogSendUploadBlock added in v0.1.0 

func (c *UserClientConn) LogSendUploadBlock(
	ctx context.Context,
	arg rem.LogSendUploadBlockArg,
) error

func (*UserClientConn) MakeInertTeamBearerToken 

func (c *UserClientConn) MakeInertTeamBearerToken(
	ctx context.Context,
	arg rem.MakeInertTeamBearerTokenArg,
) (
	rem.TeamBearerToken,
	error,
)

func (*UserClientConn) NewWebAdminPanelURL 

func (c *UserClientConn) NewWebAdminPanelURL(
	ctx context.Context,
) (
	proto.URLString,
	error,
)

func (*UserClientConn) NextPassphraseGeneration 

func (c *UserClientConn) NextPassphraseGeneration(ctx context.Context) (proto.PassphraseGeneration, error)

func (*UserClientConn) Ping 

func (c *UserClientConn) Ping(ctx context.Context) (proto.UID, error)
func (c *UserClientConn) PostGenericLink(
	ctx context.Context,
	arg rem.PostGenericLinkArg,
) error
func (u *UserClientConn) PostTeamMembershipLink(
	ctx context.Context,
	arg rem.PostTeamMembershipLinkArg,
) error

func (*UserClientConn) PostTeamRemoval 

func (u *UserClientConn) PostTeamRemoval(
	ctx context.Context,
	arg rem.PostTeamRemovalArg,
) error

func (*UserClientConn) Probe 

func (c *UserClientConn) Probe(ctx context.Context, arg rem.ProbeArg) (rem.ProbeRes, error)

func (*UserClientConn) ProvisionDevice 

func (c *UserClientConn) ProvisionDevice(ctx context.Context, arg rem.ProvisionDeviceArg) error

func (*UserClientConn) PutTeamCert 

func (u *UserClientConn) PutTeamCert(
	ctx context.Context,
	arg rem.PutTeamCertArg,
) error

func (*UserClientConn) PutYubiManagementKey 

func (c *UserClientConn) PutYubiManagementKey(
	ctx context.Context,
	yemk rem.YubiEncryptedManagementKey,
) error

func (*UserClientConn) RegisterProtocols 

func (c *UserClientConn) RegisterProtocols(m shared.MetaContext, srv *rpc.Server) error

func (*UserClientConn) RejectJoinReq 

func (u *UserClientConn) RejectJoinReq(
	ctx context.Context,
	arg rem.RejectJoinReqArg,
) error

func (*UserClientConn) ReserveTeamname 

func (c *UserClientConn) ReserveTeamname(
	ctx context.Context,
	nm proto.Name,
) (
	rem.ReserveNameRes,
	error,
)

func (*UserClientConn) ReserveUsernameForChange 

func (c *UserClientConn) ReserveUsernameForChange(ctx context.Context, u proto.Name) (rem.ReserveNameRes, error)

func (*UserClientConn) ResolveUsername 

func (c *UserClientConn) ResolveUsername(ctx context.Context, arg rem.ResolveUsernameArg) (proto.UID, error)

func (*UserClientConn) RevokeDevice 

func (c *UserClientConn) RevokeDevice(ctx context.Context, arg rem.RevokeDeviceArg) error

func (*UserClientConn) SetPassphrase 

func (c *UserClientConn) SetPassphrase(ctx context.Context, arg rem.SetPassphraseArg) error

func (*UserClientConn) StretchVersion 

func (c *UserClientConn) StretchVersion(ctx context.Context) (proto.StretchVersion, error)

func (*UserClientConn) TestQueueService 

func (c *UserClientConn) TestQueueService(ctx context.Context, arg infra.TestQueueServiceArg) ([]byte, error)

type UserServer 

type UserServer struct {
	shared.BaseRPCServer

	TestStopPostMembershipLink core.TestStopper
	TestStopPostGenericLink    core.TestStopper
	// contains filtered or unexported fields
}

func (*UserServer) CheckDeviceKey 

func (s *UserServer) CheckDeviceKey(m shared.MetaContext, uhc shared.UserHostContext, key proto.EntityID) (*proto.Role, error)

func (*UserServer) ConfigureCLIOptions 

func (s *UserServer) ConfigureCLIOptions(fs *flag.FlagSet)

func (*UserServer) NewClientConn 

func (s *UserServer) NewClientConn(xp rpc.Transporter, uhc shared.UserHostContext) shared.ClientConn

func (*UserServer) RequireAuth 

func (s *UserServer) RequireAuth() shared.AuthType

func (*UserServer) ServerType 

func (s *UserServer) ServerType() proto.ServerType

func (*UserServer) SetTestTimeTravel 

func (u *UserServer) SetTestTimeTravel(d time.Duration)

func (*UserServer) Setup 

func (s *UserServer) Setup(m shared.MetaContext) error

func (*UserServer) TestTimeTravel 

func (u *UserServer) TestTimeTravel() time.Duration

func (*UserServer) ToRPCServer 

func (s *UserServer) ToRPCServer() shared.RPCServer

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.