Documentation
¶
Index ¶
- func RegisterWatchtowerClientServer(s *grpc.Server, srv WatchtowerClientServer)
- type AddTowerRequest
- func (*AddTowerRequest) Descriptor() ([]byte, []int)
- func (m *AddTowerRequest) GetAddress() string
- func (m *AddTowerRequest) GetPubkey() []byte
- func (*AddTowerRequest) ProtoMessage()
- 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
- 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 GetTowerInfoRequest
- func (*GetTowerInfoRequest) Descriptor() ([]byte, []int)
- func (m *GetTowerInfoRequest) GetIncludeSessions() bool
- func (m *GetTowerInfoRequest) GetPubkey() []byte
- func (*GetTowerInfoRequest) ProtoMessage()
- 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
- func (*ListTowersRequest) Descriptor() ([]byte, []int)
- func (m *ListTowersRequest) GetIncludeSessions() bool
- func (*ListTowersRequest) ProtoMessage()
- 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
- func (*ListTowersResponse) Descriptor() ([]byte, []int)
- func (m *ListTowersResponse) GetTowers() []*Tower
- func (*ListTowersResponse) ProtoMessage()
- 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
- func (*PolicyRequest) Descriptor() ([]byte, []int)
- func (*PolicyRequest) ProtoMessage()
- 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
- func (*PolicyResponse) Descriptor() ([]byte, []int)
- func (m *PolicyResponse) GetMaxUpdates() uint32
- func (m *PolicyResponse) GetSweepSatPerByte() uint32
- func (*PolicyResponse) ProtoMessage()
- 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 RemoveTowerRequest
- func (*RemoveTowerRequest) Descriptor() ([]byte, []int)
- func (m *RemoveTowerRequest) GetAddress() string
- func (m *RemoveTowerRequest) GetPubkey() []byte
- func (*RemoveTowerRequest) ProtoMessage()
- 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
- 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 StatsRequest
- 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
- func (*StatsResponse) Descriptor() ([]byte, []int)
- 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 (*StatsResponse) ProtoMessage()
- 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
- func (*Tower) Descriptor() ([]byte, []int)
- 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 (*Tower) ProtoMessage()
- 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
- func (*TowerSession) Descriptor() ([]byte, []int)
- func (m *TowerSession) GetMaxBackups() uint32
- func (m *TowerSession) GetNumBackups() uint32
- func (m *TowerSession) GetNumPendingBackups() uint32
- func (m *TowerSession) GetSweepSatPerByte() uint32
- func (*TowerSession) ProtoMessage()
- 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
- 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 WatchtowerClientClient
- type WatchtowerClientServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterWatchtowerClientServer ¶
func RegisterWatchtowerClientServer(s *grpc.Server, srv WatchtowerClientServer)
Types ¶
type AddTowerRequest ¶
type AddTowerRequest struct {
// The identifying public key of the watchtower to add.
Pubkey []byte `protobuf:"bytes,1,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
// A network address the watchtower is reachable over.
Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*AddTowerRequest) Descriptor ¶
func (*AddTowerRequest) Descriptor() ([]byte, []int)
func (*AddTowerRequest) GetAddress ¶
func (m *AddTowerRequest) GetAddress() string
func (*AddTowerRequest) GetPubkey ¶
func (m *AddTowerRequest) GetPubkey() []byte
func (*AddTowerRequest) ProtoMessage ¶
func (*AddTowerRequest) ProtoMessage()
func (*AddTowerRequest) Reset ¶
func (m *AddTowerRequest) Reset()
func (*AddTowerRequest) String ¶
func (m *AddTowerRequest) String() string
func (*AddTowerRequest) XXX_DiscardUnknown ¶
func (m *AddTowerRequest) XXX_DiscardUnknown()
func (*AddTowerRequest) XXX_Marshal ¶
func (m *AddTowerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AddTowerRequest) XXX_Merge ¶
func (m *AddTowerRequest) XXX_Merge(src proto.Message)
func (*AddTowerRequest) XXX_Size ¶
func (m *AddTowerRequest) XXX_Size() int
func (*AddTowerRequest) XXX_Unmarshal ¶
func (m *AddTowerRequest) XXX_Unmarshal(b []byte) error
type AddTowerResponse ¶
type AddTowerResponse struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*AddTowerResponse) Descriptor ¶
func (*AddTowerResponse) Descriptor() ([]byte, []int)
func (*AddTowerResponse) ProtoMessage ¶
func (*AddTowerResponse) ProtoMessage()
func (*AddTowerResponse) Reset ¶
func (m *AddTowerResponse) Reset()
func (*AddTowerResponse) String ¶
func (m *AddTowerResponse) String() string
func (*AddTowerResponse) XXX_DiscardUnknown ¶
func (m *AddTowerResponse) XXX_DiscardUnknown()
func (*AddTowerResponse) XXX_Marshal ¶
func (m *AddTowerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AddTowerResponse) XXX_Merge ¶
func (m *AddTowerResponse) XXX_Merge(src proto.Message)
func (*AddTowerResponse) XXX_Size ¶
func (m *AddTowerResponse) XXX_Size() int
func (*AddTowerResponse) XXX_Unmarshal ¶
func (m *AddTowerResponse) XXX_Unmarshal(b []byte) error
type GetTowerInfoRequest ¶
type GetTowerInfoRequest struct {
// The identifying public key of the watchtower to retrieve information for.
Pubkey []byte `protobuf:"bytes,1,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
// Whether we should include sessions with the watchtower in the response.
IncludeSessions bool `protobuf:"varint,2,opt,name=include_sessions,proto3" json:"include_sessions,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*GetTowerInfoRequest) Descriptor ¶
func (*GetTowerInfoRequest) Descriptor() ([]byte, []int)
func (*GetTowerInfoRequest) GetIncludeSessions ¶
func (m *GetTowerInfoRequest) GetIncludeSessions() bool
func (*GetTowerInfoRequest) GetPubkey ¶
func (m *GetTowerInfoRequest) GetPubkey() []byte
func (*GetTowerInfoRequest) ProtoMessage ¶
func (*GetTowerInfoRequest) ProtoMessage()
func (*GetTowerInfoRequest) Reset ¶
func (m *GetTowerInfoRequest) Reset()
func (*GetTowerInfoRequest) String ¶
func (m *GetTowerInfoRequest) String() string
func (*GetTowerInfoRequest) XXX_DiscardUnknown ¶
func (m *GetTowerInfoRequest) XXX_DiscardUnknown()
func (*GetTowerInfoRequest) XXX_Marshal ¶
func (m *GetTowerInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTowerInfoRequest) XXX_Merge ¶
func (m *GetTowerInfoRequest) XXX_Merge(src proto.Message)
func (*GetTowerInfoRequest) XXX_Size ¶
func (m *GetTowerInfoRequest) XXX_Size() int
func (*GetTowerInfoRequest) XXX_Unmarshal ¶
func (m *GetTowerInfoRequest) XXX_Unmarshal(b []byte) error
type ListTowersRequest ¶
type ListTowersRequest struct {
// Whether we should include sessions with the watchtower in the response.
IncludeSessions bool `protobuf:"varint,1,opt,name=include_sessions,proto3" json:"include_sessions,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ListTowersRequest) Descriptor ¶
func (*ListTowersRequest) Descriptor() ([]byte, []int)
func (*ListTowersRequest) GetIncludeSessions ¶
func (m *ListTowersRequest) GetIncludeSessions() bool
func (*ListTowersRequest) ProtoMessage ¶
func (*ListTowersRequest) ProtoMessage()
func (*ListTowersRequest) Reset ¶
func (m *ListTowersRequest) Reset()
func (*ListTowersRequest) String ¶
func (m *ListTowersRequest) String() string
func (*ListTowersRequest) XXX_DiscardUnknown ¶
func (m *ListTowersRequest) XXX_DiscardUnknown()
func (*ListTowersRequest) XXX_Marshal ¶
func (m *ListTowersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListTowersRequest) XXX_Merge ¶
func (m *ListTowersRequest) XXX_Merge(src proto.Message)
func (*ListTowersRequest) XXX_Size ¶
func (m *ListTowersRequest) XXX_Size() int
func (*ListTowersRequest) XXX_Unmarshal ¶
func (m *ListTowersRequest) XXX_Unmarshal(b []byte) error
type ListTowersResponse ¶
type ListTowersResponse struct {
// The list of watchtowers available for new backups.
Towers []*Tower `protobuf:"bytes,1,rep,name=towers,proto3" json:"towers,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ListTowersResponse) Descriptor ¶
func (*ListTowersResponse) Descriptor() ([]byte, []int)
func (*ListTowersResponse) GetTowers ¶
func (m *ListTowersResponse) GetTowers() []*Tower
func (*ListTowersResponse) ProtoMessage ¶
func (*ListTowersResponse) ProtoMessage()
func (*ListTowersResponse) Reset ¶
func (m *ListTowersResponse) Reset()
func (*ListTowersResponse) String ¶
func (m *ListTowersResponse) String() string
func (*ListTowersResponse) XXX_DiscardUnknown ¶
func (m *ListTowersResponse) XXX_DiscardUnknown()
func (*ListTowersResponse) XXX_Marshal ¶
func (m *ListTowersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListTowersResponse) XXX_Merge ¶
func (m *ListTowersResponse) XXX_Merge(src proto.Message)
func (*ListTowersResponse) XXX_Size ¶
func (m *ListTowersResponse) XXX_Size() int
func (*ListTowersResponse) XXX_Unmarshal ¶
func (m *ListTowersResponse) XXX_Unmarshal(b []byte) error
type PolicyRequest ¶
type PolicyRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*PolicyRequest) Descriptor ¶
func (*PolicyRequest) Descriptor() ([]byte, []int)
func (*PolicyRequest) ProtoMessage ¶
func (*PolicyRequest) ProtoMessage()
func (*PolicyRequest) Reset ¶
func (m *PolicyRequest) Reset()
func (*PolicyRequest) String ¶
func (m *PolicyRequest) String() string
func (*PolicyRequest) XXX_DiscardUnknown ¶
func (m *PolicyRequest) XXX_DiscardUnknown()
func (*PolicyRequest) XXX_Marshal ¶
func (m *PolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PolicyRequest) XXX_Merge ¶
func (m *PolicyRequest) XXX_Merge(src proto.Message)
func (*PolicyRequest) XXX_Size ¶
func (m *PolicyRequest) XXX_Size() int
func (*PolicyRequest) XXX_Unmarshal ¶
func (m *PolicyRequest) XXX_Unmarshal(b []byte) error
type PolicyResponse ¶
type PolicyResponse struct {
//
//The maximum number of updates each session we negotiate with watchtowers
//should allow.
MaxUpdates uint32 `protobuf:"varint,1,opt,name=max_updates,proto3" json:"max_updates,omitempty"`
//
//The fee rate, in satoshis per vbyte, that will be used by watchtowers for
//justice transactions in response to channel breaches.
SweepSatPerByte uint32 `protobuf:"varint,2,opt,name=sweep_sat_per_byte,proto3" json:"sweep_sat_per_byte,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*PolicyResponse) Descriptor ¶
func (*PolicyResponse) Descriptor() ([]byte, []int)
func (*PolicyResponse) GetMaxUpdates ¶
func (m *PolicyResponse) GetMaxUpdates() uint32
func (*PolicyResponse) GetSweepSatPerByte ¶
func (m *PolicyResponse) GetSweepSatPerByte() uint32
func (*PolicyResponse) ProtoMessage ¶
func (*PolicyResponse) ProtoMessage()
func (*PolicyResponse) Reset ¶
func (m *PolicyResponse) Reset()
func (*PolicyResponse) String ¶
func (m *PolicyResponse) String() string
func (*PolicyResponse) XXX_DiscardUnknown ¶
func (m *PolicyResponse) XXX_DiscardUnknown()
func (*PolicyResponse) XXX_Marshal ¶
func (m *PolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PolicyResponse) XXX_Merge ¶
func (m *PolicyResponse) XXX_Merge(src proto.Message)
func (*PolicyResponse) XXX_Size ¶
func (m *PolicyResponse) XXX_Size() int
func (*PolicyResponse) XXX_Unmarshal ¶
func (m *PolicyResponse) XXX_Unmarshal(b []byte) error
type RemoveTowerRequest ¶
type RemoveTowerRequest struct {
// The identifying public key of the watchtower to remove.
Pubkey []byte `protobuf:"bytes,1,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
//
//If set, then the record for this address will be removed, indicating that is
//is stale. Otherwise, the watchtower will no longer be used for future
//session negotiations and backups.
Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*RemoveTowerRequest) Descriptor ¶
func (*RemoveTowerRequest) Descriptor() ([]byte, []int)
func (*RemoveTowerRequest) GetAddress ¶
func (m *RemoveTowerRequest) GetAddress() string
func (*RemoveTowerRequest) GetPubkey ¶
func (m *RemoveTowerRequest) GetPubkey() []byte
func (*RemoveTowerRequest) ProtoMessage ¶
func (*RemoveTowerRequest) ProtoMessage()
func (*RemoveTowerRequest) Reset ¶
func (m *RemoveTowerRequest) Reset()
func (*RemoveTowerRequest) String ¶
func (m *RemoveTowerRequest) String() string
func (*RemoveTowerRequest) XXX_DiscardUnknown ¶
func (m *RemoveTowerRequest) XXX_DiscardUnknown()
func (*RemoveTowerRequest) XXX_Marshal ¶
func (m *RemoveTowerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoveTowerRequest) XXX_Merge ¶
func (m *RemoveTowerRequest) XXX_Merge(src proto.Message)
func (*RemoveTowerRequest) XXX_Size ¶
func (m *RemoveTowerRequest) XXX_Size() int
func (*RemoveTowerRequest) XXX_Unmarshal ¶
func (m *RemoveTowerRequest) XXX_Unmarshal(b []byte) error
type RemoveTowerResponse ¶
type RemoveTowerResponse struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*RemoveTowerResponse) Descriptor ¶
func (*RemoveTowerResponse) Descriptor() ([]byte, []int)
func (*RemoveTowerResponse) ProtoMessage ¶
func (*RemoveTowerResponse) ProtoMessage()
func (*RemoveTowerResponse) Reset ¶
func (m *RemoveTowerResponse) Reset()
func (*RemoveTowerResponse) String ¶
func (m *RemoveTowerResponse) String() string
func (*RemoveTowerResponse) XXX_DiscardUnknown ¶
func (m *RemoveTowerResponse) XXX_DiscardUnknown()
func (*RemoveTowerResponse) XXX_Marshal ¶
func (m *RemoveTowerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RemoveTowerResponse) XXX_Merge ¶
func (m *RemoveTowerResponse) XXX_Merge(src proto.Message)
func (*RemoveTowerResponse) XXX_Size ¶
func (m *RemoveTowerResponse) XXX_Size() int
func (*RemoveTowerResponse) XXX_Unmarshal ¶
func (m *RemoveTowerResponse) XXX_Unmarshal(b []byte) error
type StatsRequest ¶
type StatsRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*StatsRequest) Descriptor ¶
func (*StatsRequest) Descriptor() ([]byte, []int)
func (*StatsRequest) ProtoMessage ¶
func (*StatsRequest) ProtoMessage()
func (*StatsRequest) Reset ¶
func (m *StatsRequest) Reset()
func (*StatsRequest) String ¶
func (m *StatsRequest) String() string
func (*StatsRequest) XXX_DiscardUnknown ¶
func (m *StatsRequest) XXX_DiscardUnknown()
func (*StatsRequest) XXX_Marshal ¶
func (m *StatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatsRequest) XXX_Merge ¶
func (m *StatsRequest) XXX_Merge(src proto.Message)
func (*StatsRequest) XXX_Size ¶
func (m *StatsRequest) XXX_Size() int
func (*StatsRequest) XXX_Unmarshal ¶
func (m *StatsRequest) XXX_Unmarshal(b []byte) error
type StatsResponse ¶
type StatsResponse struct {
//
//The total number of backups made to all active and exhausted watchtower
//sessions.
NumBackups uint32 `protobuf:"varint,1,opt,name=num_backups,proto3" json:"num_backups,omitempty"`
//
//The total number of backups that are pending to be acknowledged by all
//active and exhausted watchtower sessions.
NumPendingBackups uint32 `protobuf:"varint,2,opt,name=num_pending_backups,proto3" json:"num_pending_backups,omitempty"`
//
//The total number of backups that all active and exhausted watchtower
//sessions have failed to acknowledge.
NumFailedBackups uint32 `protobuf:"varint,3,opt,name=num_failed_backups,proto3" json:"num_failed_backups,omitempty"`
// The total number of new sessions made to watchtowers.
NumSessionsAcquired uint32 `protobuf:"varint,4,opt,name=num_sessions_acquired,proto3" json:"num_sessions_acquired,omitempty"`
// The total number of watchtower sessions that have been exhausted.
NumSessionsExhausted uint32 `protobuf:"varint,5,opt,name=num_sessions_exhausted,proto3" json:"num_sessions_exhausted,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*StatsResponse) Descriptor ¶
func (*StatsResponse) Descriptor() ([]byte, []int)
func (*StatsResponse) GetNumBackups ¶
func (m *StatsResponse) GetNumBackups() uint32
func (*StatsResponse) GetNumFailedBackups ¶
func (m *StatsResponse) GetNumFailedBackups() uint32
func (*StatsResponse) GetNumPendingBackups ¶
func (m *StatsResponse) GetNumPendingBackups() uint32
func (*StatsResponse) GetNumSessionsAcquired ¶
func (m *StatsResponse) GetNumSessionsAcquired() uint32
func (*StatsResponse) GetNumSessionsExhausted ¶
func (m *StatsResponse) GetNumSessionsExhausted() uint32
func (*StatsResponse) ProtoMessage ¶
func (*StatsResponse) ProtoMessage()
func (*StatsResponse) Reset ¶
func (m *StatsResponse) Reset()
func (*StatsResponse) String ¶
func (m *StatsResponse) String() string
func (*StatsResponse) XXX_DiscardUnknown ¶
func (m *StatsResponse) XXX_DiscardUnknown()
func (*StatsResponse) XXX_Marshal ¶
func (m *StatsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StatsResponse) XXX_Merge ¶
func (m *StatsResponse) XXX_Merge(src proto.Message)
func (*StatsResponse) XXX_Size ¶
func (m *StatsResponse) XXX_Size() int
func (*StatsResponse) XXX_Unmarshal ¶
func (m *StatsResponse) XXX_Unmarshal(b []byte) error
type Tower ¶
type Tower struct {
// The identifying public key of the watchtower.
Pubkey []byte `protobuf:"bytes,1,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
// The list of addresses the watchtower is reachable over.
Addresses []string `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"`
// Whether the watchtower is currently a candidate for new sessions.
ActiveSessionCandidate bool `protobuf:"varint,3,opt,name=active_session_candidate,proto3" json:"active_session_candidate,omitempty"`
// The number of sessions that have been negotiated with the watchtower.
NumSessions uint32 `protobuf:"varint,4,opt,name=num_sessions,proto3" json:"num_sessions,omitempty"`
// The list of sessions that have been negotiated with the watchtower.
Sessions []*TowerSession `protobuf:"bytes,5,rep,name=sessions,proto3" json:"sessions,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Tower) Descriptor ¶
func (*Tower) GetActiveSessionCandidate ¶
func (*Tower) GetAddresses ¶
func (*Tower) GetNumSessions ¶
func (*Tower) GetSessions ¶
func (m *Tower) GetSessions() []*TowerSession
func (*Tower) ProtoMessage ¶
func (*Tower) ProtoMessage()
func (*Tower) XXX_DiscardUnknown ¶
func (m *Tower) XXX_DiscardUnknown()
func (*Tower) XXX_Marshal ¶
func (*Tower) XXX_Unmarshal ¶
type TowerSession ¶
type TowerSession struct {
//
//The total number of successful backups that have been made to the
//watchtower session.
NumBackups uint32 `protobuf:"varint,1,opt,name=num_backups,proto3" json:"num_backups,omitempty"`
//
//The total number of backups in the session that are currently pending to be
//acknowledged by the watchtower.
NumPendingBackups uint32 `protobuf:"varint,2,opt,name=num_pending_backups,proto3" json:"num_pending_backups,omitempty"`
// The maximum number of backups allowed by the watchtower session.
MaxBackups uint32 `protobuf:"varint,3,opt,name=max_backups,proto3" json:"max_backups,omitempty"`
//
//The fee rate, in satoshis per vbyte, that will be used by the watchtower for
//the justice transaction in the event of a channel breach.
SweepSatPerByte uint32 `protobuf:"varint,4,opt,name=sweep_sat_per_byte,proto3" json:"sweep_sat_per_byte,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*TowerSession) Descriptor ¶
func (*TowerSession) Descriptor() ([]byte, []int)
func (*TowerSession) GetMaxBackups ¶
func (m *TowerSession) GetMaxBackups() uint32
func (*TowerSession) GetNumBackups ¶
func (m *TowerSession) GetNumBackups() uint32
func (*TowerSession) GetNumPendingBackups ¶
func (m *TowerSession) GetNumPendingBackups() uint32
func (*TowerSession) GetSweepSatPerByte ¶
func (m *TowerSession) GetSweepSatPerByte() uint32
func (*TowerSession) ProtoMessage ¶
func (*TowerSession) ProtoMessage()
func (*TowerSession) Reset ¶
func (m *TowerSession) Reset()
func (*TowerSession) String ¶
func (m *TowerSession) String() string
func (*TowerSession) XXX_DiscardUnknown ¶
func (m *TowerSession) XXX_DiscardUnknown()
func (*TowerSession) XXX_Marshal ¶
func (m *TowerSession) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TowerSession) XXX_Merge ¶
func (m *TowerSession) XXX_Merge(src proto.Message)
func (*TowerSession) XXX_Size ¶
func (m *TowerSession) XXX_Size() int
func (*TowerSession) XXX_Unmarshal ¶
func (m *TowerSession) XXX_Unmarshal(b []byte) error
type UnimplementedWatchtowerClientServer ¶
type UnimplementedWatchtowerClientServer struct {
}
UnimplementedWatchtowerClientServer can be embedded to have forward compatible implementations.
func (*UnimplementedWatchtowerClientServer) AddTower ¶
func (*UnimplementedWatchtowerClientServer) AddTower(ctx context.Context, req *AddTowerRequest) (*AddTowerResponse, error)
func (*UnimplementedWatchtowerClientServer) GetTowerInfo ¶
func (*UnimplementedWatchtowerClientServer) GetTowerInfo(ctx context.Context, req *GetTowerInfoRequest) (*Tower, error)
func (*UnimplementedWatchtowerClientServer) ListTowers ¶
func (*UnimplementedWatchtowerClientServer) ListTowers(ctx context.Context, req *ListTowersRequest) (*ListTowersResponse, error)
func (*UnimplementedWatchtowerClientServer) Policy ¶
func (*UnimplementedWatchtowerClientServer) Policy(ctx context.Context, req *PolicyRequest) (*PolicyResponse, error)
func (*UnimplementedWatchtowerClientServer) RemoveTower ¶
func (*UnimplementedWatchtowerClientServer) RemoveTower(ctx context.Context, req *RemoveTowerRequest) (*RemoveTowerResponse, error)
func (*UnimplementedWatchtowerClientServer) Stats ¶
func (*UnimplementedWatchtowerClientServer) Stats(ctx context.Context, req *StatsRequest) (*StatsResponse, error)
type WatchtowerClientClient ¶
type WatchtowerClientClient interface {
//
//AddTower adds a new watchtower reachable at the given address and
//considers it for new sessions. If the watchtower already exists, then
//any new addresses included will be considered when dialing it for
//session negotiations and backups.
AddTower(ctx context.Context, in *AddTowerRequest, opts ...grpc.CallOption) (*AddTowerResponse, error)
//
//RemoveTower removes a watchtower from being considered for future session
//negotiations and from being used for any subsequent backups until it's added
//again. If an address is provided, then this RPC only serves as a way of
//removing the address from the watchtower instead.
RemoveTower(ctx context.Context, in *RemoveTowerRequest, opts ...grpc.CallOption) (*RemoveTowerResponse, error)
// ListTowers returns the list of watchtowers registered with the client.
ListTowers(ctx context.Context, in *ListTowersRequest, opts ...grpc.CallOption) (*ListTowersResponse, error)
// GetTowerInfo retrieves information for a registered watchtower.
GetTowerInfo(ctx context.Context, in *GetTowerInfoRequest, opts ...grpc.CallOption) (*Tower, error)
// Stats returns the in-memory statistics of the client since startup.
Stats(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*StatsResponse, error)
// Policy returns the active watchtower client policy configuration.
Policy(ctx context.Context, in *PolicyRequest, opts ...grpc.CallOption) (*PolicyResponse, error)
}
WatchtowerClientClient is the client API for WatchtowerClient service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewWatchtowerClientClient ¶
func NewWatchtowerClientClient(cc grpc.ClientConnInterface) WatchtowerClientClient
type WatchtowerClientServer ¶
type WatchtowerClientServer interface {
//
//AddTower adds a new watchtower reachable at the given address and
//considers it for new sessions. If the watchtower already exists, then
//any new addresses included will be considered when dialing it for
//session negotiations and backups.
AddTower(context.Context, *AddTowerRequest) (*AddTowerResponse, error)
//
//RemoveTower removes a watchtower from being considered for future session
//negotiations and from being used for any subsequent backups until it's added
//again. If an address is provided, then this RPC only serves as a way of
//removing the address from the watchtower instead.
RemoveTower(context.Context, *RemoveTowerRequest) (*RemoveTowerResponse, error)
// ListTowers returns the list of watchtowers registered with the client.
ListTowers(context.Context, *ListTowersRequest) (*ListTowersResponse, error)
// GetTowerInfo retrieves information for a registered watchtower.
GetTowerInfo(context.Context, *GetTowerInfoRequest) (*Tower, error)
// Stats returns the in-memory statistics of the client since startup.
Stats(context.Context, *StatsRequest) (*StatsResponse, error)
// Policy returns the active watchtower client policy configuration.
Policy(context.Context, *PolicyRequest) (*PolicyResponse, error)
}
WatchtowerClientServer is the server API for WatchtowerClient service.
Click to show internal directories.
Click to hide internal directories.