Versions in this module Expand all Collapse all v0 v0.12.2 Mar 18, 2021 Changes in this version + var ErrWtclientNotActive = errors.New("watchtower client not active") + var PolicyType_name = map[int32]string + var PolicyType_value = map[string]int32 + func RegisterWatchtowerClientHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error + func RegisterWatchtowerClientHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WatchtowerClientClient) error + func RegisterWatchtowerClientHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error) + func RegisterWatchtowerClientHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WatchtowerClientServer) error + func RegisterWatchtowerClientServer(s *grpc.Server, srv WatchtowerClientServer) + type AddTowerRequest struct + Address string + Pubkey []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AddTowerRequest) Descriptor() ([]byte, []int) + func (*AddTowerRequest) ProtoMessage() + func (m *AddTowerRequest) GetAddress() string + func (m *AddTowerRequest) GetPubkey() []byte + func (m *AddTowerRequest) Reset() + func (m *AddTowerRequest) String() string + func (m *AddTowerRequest) XXX_DiscardUnknown() + func (m *AddTowerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AddTowerRequest) XXX_Merge(src proto.Message) + func (m *AddTowerRequest) XXX_Size() int + func (m *AddTowerRequest) XXX_Unmarshal(b []byte) error + type AddTowerResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AddTowerResponse) Descriptor() ([]byte, []int) + func (*AddTowerResponse) ProtoMessage() + func (m *AddTowerResponse) Reset() + func (m *AddTowerResponse) String() string + func (m *AddTowerResponse) XXX_DiscardUnknown() + func (m *AddTowerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *AddTowerResponse) XXX_Merge(src proto.Message) + func (m *AddTowerResponse) XXX_Size() int + func (m *AddTowerResponse) XXX_Unmarshal(b []byte) error + type Config struct + Active bool + AnchorClient wtclient.Client + Client wtclient.Client + Log btclog.Logger + Resolver lncfg.TCPResolver + type GetTowerInfoRequest struct + IncludeSessions bool + Pubkey []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetTowerInfoRequest) Descriptor() ([]byte, []int) + func (*GetTowerInfoRequest) ProtoMessage() + func (m *GetTowerInfoRequest) GetIncludeSessions() bool + func (m *GetTowerInfoRequest) GetPubkey() []byte + func (m *GetTowerInfoRequest) Reset() + func (m *GetTowerInfoRequest) String() string + func (m *GetTowerInfoRequest) XXX_DiscardUnknown() + func (m *GetTowerInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetTowerInfoRequest) XXX_Merge(src proto.Message) + func (m *GetTowerInfoRequest) XXX_Size() int + func (m *GetTowerInfoRequest) XXX_Unmarshal(b []byte) error + type ListTowersRequest struct + IncludeSessions bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListTowersRequest) Descriptor() ([]byte, []int) + func (*ListTowersRequest) ProtoMessage() + func (m *ListTowersRequest) GetIncludeSessions() bool + func (m *ListTowersRequest) Reset() + func (m *ListTowersRequest) String() string + func (m *ListTowersRequest) XXX_DiscardUnknown() + func (m *ListTowersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListTowersRequest) XXX_Merge(src proto.Message) + func (m *ListTowersRequest) XXX_Size() int + func (m *ListTowersRequest) XXX_Unmarshal(b []byte) error + type ListTowersResponse struct + Towers []*Tower + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListTowersResponse) Descriptor() ([]byte, []int) + func (*ListTowersResponse) ProtoMessage() + func (m *ListTowersResponse) GetTowers() []*Tower + func (m *ListTowersResponse) Reset() + func (m *ListTowersResponse) String() string + func (m *ListTowersResponse) XXX_DiscardUnknown() + func (m *ListTowersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListTowersResponse) XXX_Merge(src proto.Message) + func (m *ListTowersResponse) XXX_Size() int + func (m *ListTowersResponse) XXX_Unmarshal(b []byte) error + type PolicyRequest struct + PolicyType PolicyType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PolicyRequest) Descriptor() ([]byte, []int) + func (*PolicyRequest) ProtoMessage() + func (m *PolicyRequest) GetPolicyType() PolicyType + func (m *PolicyRequest) Reset() + func (m *PolicyRequest) String() string + func (m *PolicyRequest) XXX_DiscardUnknown() + func (m *PolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PolicyRequest) XXX_Merge(src proto.Message) + func (m *PolicyRequest) XXX_Size() int + func (m *PolicyRequest) XXX_Unmarshal(b []byte) error + type PolicyResponse struct + MaxUpdates uint32 + SweepSatPerByte uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PolicyResponse) Descriptor() ([]byte, []int) + func (*PolicyResponse) ProtoMessage() + func (m *PolicyResponse) GetMaxUpdates() uint32 + func (m *PolicyResponse) GetSweepSatPerByte() uint32 + func (m *PolicyResponse) Reset() + func (m *PolicyResponse) String() string + func (m *PolicyResponse) XXX_DiscardUnknown() + func (m *PolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PolicyResponse) XXX_Merge(src proto.Message) + func (m *PolicyResponse) XXX_Size() int + func (m *PolicyResponse) XXX_Unmarshal(b []byte) error + type PolicyType int32 + const PolicyType_ANCHOR + const PolicyType_LEGACY + func (PolicyType) EnumDescriptor() ([]byte, []int) + func (x PolicyType) String() string + type RemoveTowerRequest struct + Address string + Pubkey []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RemoveTowerRequest) Descriptor() ([]byte, []int) + func (*RemoveTowerRequest) ProtoMessage() + func (m *RemoveTowerRequest) GetAddress() string + func (m *RemoveTowerRequest) GetPubkey() []byte + func (m *RemoveTowerRequest) Reset() + func (m *RemoveTowerRequest) String() string + func (m *RemoveTowerRequest) XXX_DiscardUnknown() + func (m *RemoveTowerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RemoveTowerRequest) XXX_Merge(src proto.Message) + func (m *RemoveTowerRequest) XXX_Size() int + func (m *RemoveTowerRequest) XXX_Unmarshal(b []byte) error + type RemoveTowerResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RemoveTowerResponse) Descriptor() ([]byte, []int) + func (*RemoveTowerResponse) ProtoMessage() + func (m *RemoveTowerResponse) Reset() + func (m *RemoveTowerResponse) String() string + func (m *RemoveTowerResponse) XXX_DiscardUnknown() + func (m *RemoveTowerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RemoveTowerResponse) XXX_Merge(src proto.Message) + func (m *RemoveTowerResponse) XXX_Size() int + func (m *RemoveTowerResponse) XXX_Unmarshal(b []byte) error + type ServerShell struct + func (r *ServerShell) CreateSubServer(configRegistry lnrpc.SubServerConfigDispatcher) (lnrpc.SubServer, lnrpc.MacaroonPerms, error) + func (r *ServerShell) RegisterWithRestServer(ctx context.Context, mux *runtime.ServeMux, dest string, ...) error + func (r *ServerShell) RegisterWithRootServer(grpcServer *grpc.Server) error + type StatsRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StatsRequest) Descriptor() ([]byte, []int) + func (*StatsRequest) ProtoMessage() + func (m *StatsRequest) Reset() + func (m *StatsRequest) String() string + func (m *StatsRequest) XXX_DiscardUnknown() + func (m *StatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StatsRequest) XXX_Merge(src proto.Message) + func (m *StatsRequest) XXX_Size() int + func (m *StatsRequest) XXX_Unmarshal(b []byte) error + type StatsResponse struct + NumBackups uint32 + NumFailedBackups uint32 + NumPendingBackups uint32 + NumSessionsAcquired uint32 + NumSessionsExhausted uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StatsResponse) Descriptor() ([]byte, []int) + func (*StatsResponse) ProtoMessage() + func (m *StatsResponse) GetNumBackups() uint32 + func (m *StatsResponse) GetNumFailedBackups() uint32 + func (m *StatsResponse) GetNumPendingBackups() uint32 + func (m *StatsResponse) GetNumSessionsAcquired() uint32 + func (m *StatsResponse) GetNumSessionsExhausted() uint32 + func (m *StatsResponse) Reset() + func (m *StatsResponse) String() string + func (m *StatsResponse) XXX_DiscardUnknown() + func (m *StatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StatsResponse) XXX_Merge(src proto.Message) + func (m *StatsResponse) XXX_Size() int + func (m *StatsResponse) XXX_Unmarshal(b []byte) error + type Tower struct + ActiveSessionCandidate bool + Addresses []string + NumSessions uint32 + Pubkey []byte + Sessions []*TowerSession + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Tower) Descriptor() ([]byte, []int) + func (*Tower) ProtoMessage() + func (m *Tower) GetActiveSessionCandidate() bool + func (m *Tower) GetAddresses() []string + func (m *Tower) GetNumSessions() uint32 + func (m *Tower) GetPubkey() []byte + func (m *Tower) GetSessions() []*TowerSession + func (m *Tower) Reset() + func (m *Tower) String() string + func (m *Tower) XXX_DiscardUnknown() + func (m *Tower) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Tower) XXX_Merge(src proto.Message) + func (m *Tower) XXX_Size() int + func (m *Tower) XXX_Unmarshal(b []byte) error + type TowerSession struct + MaxBackups uint32 + NumBackups uint32 + NumPendingBackups uint32 + SweepSatPerByte uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TowerSession) Descriptor() ([]byte, []int) + func (*TowerSession) ProtoMessage() + func (m *TowerSession) GetMaxBackups() uint32 + func (m *TowerSession) GetNumBackups() uint32 + func (m *TowerSession) GetNumPendingBackups() uint32 + func (m *TowerSession) GetSweepSatPerByte() uint32 + func (m *TowerSession) Reset() + func (m *TowerSession) String() string + func (m *TowerSession) XXX_DiscardUnknown() + func (m *TowerSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TowerSession) XXX_Merge(src proto.Message) + func (m *TowerSession) XXX_Size() int + func (m *TowerSession) XXX_Unmarshal(b []byte) error + type UnimplementedWatchtowerClientServer struct + func (*UnimplementedWatchtowerClientServer) AddTower(ctx context.Context, req *AddTowerRequest) (*AddTowerResponse, error) + func (*UnimplementedWatchtowerClientServer) GetTowerInfo(ctx context.Context, req *GetTowerInfoRequest) (*Tower, error) + func (*UnimplementedWatchtowerClientServer) ListTowers(ctx context.Context, req *ListTowersRequest) (*ListTowersResponse, error) + func (*UnimplementedWatchtowerClientServer) Policy(ctx context.Context, req *PolicyRequest) (*PolicyResponse, error) + func (*UnimplementedWatchtowerClientServer) RemoveTower(ctx context.Context, req *RemoveTowerRequest) (*RemoveTowerResponse, error) + func (*UnimplementedWatchtowerClientServer) Stats(ctx context.Context, req *StatsRequest) (*StatsResponse, error) + type WatchtowerClient struct + func New(cfg *Config) (*WatchtowerClient, lnrpc.MacaroonPerms, error) + func (c *WatchtowerClient) AddTower(ctx context.Context, req *AddTowerRequest) (*AddTowerResponse, error) + func (c *WatchtowerClient) GetTowerInfo(ctx context.Context, req *GetTowerInfoRequest) (*Tower, error) + func (c *WatchtowerClient) ListTowers(ctx context.Context, req *ListTowersRequest) (*ListTowersResponse, error) + func (c *WatchtowerClient) Name() string + func (c *WatchtowerClient) Policy(ctx context.Context, req *PolicyRequest) (*PolicyResponse, error) + func (c *WatchtowerClient) RemoveTower(ctx context.Context, req *RemoveTowerRequest) (*RemoveTowerResponse, error) + func (c *WatchtowerClient) Start() error + func (c *WatchtowerClient) Stats(ctx context.Context, req *StatsRequest) (*StatsResponse, error) + func (c *WatchtowerClient) Stop() error + type WatchtowerClientClient interface + AddTower func(ctx context.Context, in *AddTowerRequest, opts ...grpc.CallOption) (*AddTowerResponse, error) + GetTowerInfo func(ctx context.Context, in *GetTowerInfoRequest, opts ...grpc.CallOption) (*Tower, error) + ListTowers func(ctx context.Context, in *ListTowersRequest, opts ...grpc.CallOption) (*ListTowersResponse, error) + Policy func(ctx context.Context, in *PolicyRequest, opts ...grpc.CallOption) (*PolicyResponse, error) + RemoveTower func(ctx context.Context, in *RemoveTowerRequest, opts ...grpc.CallOption) (*RemoveTowerResponse, error) + Stats func(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*StatsResponse, error) + func NewWatchtowerClientClient(cc *grpc.ClientConn) WatchtowerClientClient + type WatchtowerClientServer interface + AddTower func(context.Context, *AddTowerRequest) (*AddTowerResponse, error) + GetTowerInfo func(context.Context, *GetTowerInfoRequest) (*Tower, error) + ListTowers func(context.Context, *ListTowersRequest) (*ListTowersResponse, error) + Policy func(context.Context, *PolicyRequest) (*PolicyResponse, error) + RemoveTower func(context.Context, *RemoveTowerRequest) (*RemoveTowerResponse, error) + Stats func(context.Context, *StatsRequest) (*StatsResponse, error)