autoswaprpc

package
v2.3.5 Latest Latest
Warning

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

 Go to latest Published: Jan 11, 2025 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	AutoSwap_GetRecommendations_FullMethodName     = "/autoswaprpc.AutoSwap/GetRecommendations"
	AutoSwap_ExecuteRecommendations_FullMethodName = "/autoswaprpc.AutoSwap/ExecuteRecommendations"
	AutoSwap_GetStatus_FullMethodName              = "/autoswaprpc.AutoSwap/GetStatus"
	AutoSwap_UpdateLightningConfig_FullMethodName  = "/autoswaprpc.AutoSwap/UpdateLightningConfig"
	AutoSwap_UpdateChainConfig_FullMethodName      = "/autoswaprpc.AutoSwap/UpdateChainConfig"
	AutoSwap_GetConfig_FullMethodName              = "/autoswaprpc.AutoSwap/GetConfig"
	AutoSwap_ReloadConfig_FullMethodName           = "/autoswaprpc.AutoSwap/ReloadConfig"
)

Variables

View Source 
var AutoSwap_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "autoswaprpc.AutoSwap",
	HandlerType: (*AutoSwapServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetRecommendations",
			Handler:    _AutoSwap_GetRecommendations_Handler,
		},
		{
			MethodName: "ExecuteRecommendations",
			Handler:    _AutoSwap_ExecuteRecommendations_Handler,
		},
		{
			MethodName: "GetStatus",
			Handler:    _AutoSwap_GetStatus_Handler,
		},
		{
			MethodName: "UpdateLightningConfig",
			Handler:    _AutoSwap_UpdateLightningConfig_Handler,
		},
		{
			MethodName: "UpdateChainConfig",
			Handler:    _AutoSwap_UpdateChainConfig_Handler,
		},
		{
			MethodName: "GetConfig",
			Handler:    _AutoSwap_GetConfig_Handler,
		},
		{
			MethodName: "ReloadConfig",
			Handler:    _AutoSwap_ReloadConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "autoswaprpc/autoswaprpc.proto",
}

AutoSwap_ServiceDesc is the grpc.ServiceDesc for AutoSwap service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_autoswaprpc_autoswaprpc_proto protoreflect.FileDescriptor

Functions

func RegisterAutoSwapServer 

func RegisterAutoSwapServer(s grpc.ServiceRegistrar, srv AutoSwapServer)

Types

type AutoSwapClient 

type AutoSwapClient interface {
	//
	//Returns a list of swaps which are currently recommended by autoswap. Also works when autoswap is not running.
	GetRecommendations(ctx context.Context, in *GetRecommendationsRequest, opts ...grpc.CallOption) (*GetRecommendationsResponse, error)
	//
	//Executes recommendations previously returned by `GetRecommendations`.
	//Intended to be used when autoswap is fully configured but not enabled to allow for manual approval.
	ExecuteRecommendations(ctx context.Context, in *ExecuteRecommendationsRequest, opts ...grpc.CallOption) (*ExecuteRecommendationsResponse, error)
	//
	//Returns the current budget of autoswap and some relevant stats.
	GetStatus(ctx context.Context, in *GetStatusRequest, opts ...grpc.CallOption) (*GetStatusResponse, error)
	// Updates the lightning configuration entirely or partially. Autoswap will reload the configuration after this call.
	UpdateLightningConfig(ctx context.Context, in *UpdateLightningConfigRequest, opts ...grpc.CallOption) (*Config, error)
	//
	//Updates the chain configuration entirely or partially. Autoswap will reload the configuration after this call.
	UpdateChainConfig(ctx context.Context, in *UpdateChainConfigRequest, opts ...grpc.CallOption) (*Config, error)
	//
	//Returns the currently used configuration.
	GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*Config, error)
	//
	//Reloads the configuration from disk.
	ReloadConfig(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Config, error)
}

AutoSwapClient is the client API for AutoSwap service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAutoSwapClient 

func NewAutoSwapClient(cc grpc.ClientConnInterface) AutoSwapClient

type AutoSwapServer 

type AutoSwapServer interface {
	//
	//Returns a list of swaps which are currently recommended by autoswap. Also works when autoswap is not running.
	GetRecommendations(context.Context, *GetRecommendationsRequest) (*GetRecommendationsResponse, error)
	//
	//Executes recommendations previously returned by `GetRecommendations`.
	//Intended to be used when autoswap is fully configured but not enabled to allow for manual approval.
	ExecuteRecommendations(context.Context, *ExecuteRecommendationsRequest) (*ExecuteRecommendationsResponse, error)
	//
	//Returns the current budget of autoswap and some relevant stats.
	GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)
	// Updates the lightning configuration entirely or partially. Autoswap will reload the configuration after this call.
	UpdateLightningConfig(context.Context, *UpdateLightningConfigRequest) (*Config, error)
	//
	//Updates the chain configuration entirely or partially. Autoswap will reload the configuration after this call.
	UpdateChainConfig(context.Context, *UpdateChainConfigRequest) (*Config, error)
	//
	//Returns the currently used configuration.
	GetConfig(context.Context, *GetConfigRequest) (*Config, error)
	//
	//Reloads the configuration from disk.
	ReloadConfig(context.Context, *empty.Empty) (*Config, error)
	// contains filtered or unexported methods
}

AutoSwapServer is the server API for AutoSwap service. All implementations must embed UnimplementedAutoSwapServer for forward compatibility

type Budget 

type Budget struct {
	Total     uint64              `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Remaining uint64              `protobuf:"varint,2,opt,name=remaining,proto3" json:"remaining,omitempty"`
	StartDate int64               `protobuf:"varint,3,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	EndDate   int64               `protobuf:"varint,4,opt,name=end_date,json=endDate,proto3" json:"end_date,omitempty"`
	Stats     *boltzrpc.SwapStats `protobuf:"bytes,5,opt,name=stats,proto3,oneof" json:"stats,omitempty"`
	// contains filtered or unexported fields
}

func (*Budget) Descriptor deprecated 

func (*Budget) Descriptor() ([]byte, []int)

Deprecated: Use Budget.ProtoReflect.Descriptor instead.

func (*Budget) GetEndDate 

func (x *Budget) GetEndDate() int64

func (*Budget) GetRemaining 

func (x *Budget) GetRemaining() uint64

func (*Budget) GetStartDate 

func (x *Budget) GetStartDate() int64

func (*Budget) GetStats 

func (x *Budget) GetStats() *boltzrpc.SwapStats

func (*Budget) GetTotal 

func (x *Budget) GetTotal() uint64

func (*Budget) ProtoMessage 

func (*Budget) ProtoMessage()

func (*Budget) ProtoReflect 

func (x *Budget) ProtoReflect() protoreflect.Message

func (*Budget) Reset 

func (x *Budget) Reset()

func (*Budget) String 

func (x *Budget) String() string

type ChainConfig 

type ChainConfig struct {
	Enabled        bool    `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	FromWallet     string  `protobuf:"bytes,2,opt,name=from_wallet,json=fromWallet,proto3" json:"from_wallet,omitempty"`
	ToWallet       string  `protobuf:"bytes,3,opt,name=to_wallet,json=toWallet,proto3" json:"to_wallet,omitempty"`
	ToAddress      string  `protobuf:"bytes,4,opt,name=to_address,json=toAddress,proto3" json:"to_address,omitempty"`
	MaxBalance     uint64  `protobuf:"varint,5,opt,name=max_balance,json=maxBalance,proto3" json:"max_balance,omitempty"`
	ReserveBalance uint64  `protobuf:"varint,10,opt,name=reserve_balance,json=reserveBalance,proto3" json:"reserve_balance,omitempty"`
	MaxFeePercent  float32 `protobuf:"fixed32,6,opt,name=max_fee_percent,json=maxFeePercent,proto3" json:"max_fee_percent,omitempty"`
	Budget         uint64  `protobuf:"varint,7,opt,name=budget,proto3" json:"budget,omitempty"`
	BudgetInterval uint64  `protobuf:"varint,8,opt,name=budget_interval,json=budgetInterval,proto3" json:"budget_interval,omitempty"`
	Tenant         *string `protobuf:"bytes,9,opt,name=tenant,proto3,oneof" json:"tenant,omitempty"`
	// contains filtered or unexported fields
}

func (*ChainConfig) Descriptor deprecated 

func (*ChainConfig) Descriptor() ([]byte, []int)

Deprecated: Use ChainConfig.ProtoReflect.Descriptor instead.

func (*ChainConfig) GetBudget 

func (x *ChainConfig) GetBudget() uint64

func (*ChainConfig) GetBudgetInterval 

func (x *ChainConfig) GetBudgetInterval() uint64

func (*ChainConfig) GetEnabled 

func (x *ChainConfig) GetEnabled() bool

func (*ChainConfig) GetFromWallet 

func (x *ChainConfig) GetFromWallet() string

func (*ChainConfig) GetMaxBalance 

func (x *ChainConfig) GetMaxBalance() uint64

func (*ChainConfig) GetMaxFeePercent 

func (x *ChainConfig) GetMaxFeePercent() float32

func (*ChainConfig) GetReserveBalance 

func (x *ChainConfig) GetReserveBalance() uint64

func (*ChainConfig) GetTenant 

func (x *ChainConfig) GetTenant() string

func (*ChainConfig) GetToAddress 

func (x *ChainConfig) GetToAddress() string

func (*ChainConfig) GetToWallet 

func (x *ChainConfig) GetToWallet() string

func (*ChainConfig) ProtoMessage 

func (*ChainConfig) ProtoMessage()

func (*ChainConfig) ProtoReflect 

func (x *ChainConfig) ProtoReflect() protoreflect.Message

func (*ChainConfig) Reset 

func (x *ChainConfig) Reset()

func (*ChainConfig) String 

func (x *ChainConfig) String() string

type ChainRecommendation 

type ChainRecommendation struct {

	// Populated when a swap is recommended based on the current balance of the configured `from_wallet`
	Swap          *ChainSwap        `protobuf:"bytes,1,opt,name=swap,proto3,oneof" json:"swap,omitempty"`
	WalletBalance *boltzrpc.Balance `protobuf:"bytes,2,opt,name=wallet_balance,json=walletBalance,proto3" json:"wallet_balance,omitempty"`
	// Currently configured max_balance
	MaxBalance uint64 `protobuf:"varint,3,opt,name=max_balance,json=maxBalance,proto3" json:"max_balance,omitempty"`
	// contains filtered or unexported fields
}

func (*ChainRecommendation) Descriptor deprecated 

func (*ChainRecommendation) Descriptor() ([]byte, []int)

Deprecated: Use ChainRecommendation.ProtoReflect.Descriptor instead.

func (*ChainRecommendation) GetMaxBalance 

func (x *ChainRecommendation) GetMaxBalance() uint64

func (*ChainRecommendation) GetSwap 

func (x *ChainRecommendation) GetSwap() *ChainSwap

func (*ChainRecommendation) GetWalletBalance 

func (x *ChainRecommendation) GetWalletBalance() *boltzrpc.Balance

func (*ChainRecommendation) ProtoMessage 

func (*ChainRecommendation) ProtoMessage()

func (*ChainRecommendation) ProtoReflect 

func (x *ChainRecommendation) ProtoReflect() protoreflect.Message

func (*ChainRecommendation) Reset 

func (x *ChainRecommendation) Reset()

func (*ChainRecommendation) String 

func (x *ChainRecommendation) String() string

type ChainSwap 

type ChainSwap struct {
	Amount      uint64 `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty"`
	FeeEstimate uint64 `protobuf:"varint,2,opt,name=fee_estimate,json=feeEstimate,proto3" json:"fee_estimate,omitempty"`
	// Reasons for which the swap is not being executed
	DismissedReasons []string `protobuf:"bytes,3,rep,name=dismissed_reasons,json=dismissedReasons,proto3" json:"dismissed_reasons,omitempty"`
	// contains filtered or unexported fields
}

func (*ChainSwap) Descriptor deprecated 

func (*ChainSwap) Descriptor() ([]byte, []int)

Deprecated: Use ChainSwap.ProtoReflect.Descriptor instead.

func (*ChainSwap) GetAmount 

func (x *ChainSwap) GetAmount() uint64

func (*ChainSwap) GetDismissedReasons 

func (x *ChainSwap) GetDismissedReasons() []string

func (*ChainSwap) GetFeeEstimate 

func (x *ChainSwap) GetFeeEstimate() uint64

func (*ChainSwap) ProtoMessage 

func (*ChainSwap) ProtoMessage()

func (*ChainSwap) ProtoReflect 

func (x *ChainSwap) ProtoReflect() protoreflect.Message

func (*ChainSwap) Reset 

func (x *ChainSwap) Reset()

func (*ChainSwap) String 

func (x *ChainSwap) String() string

type Config 

type Config struct {
	Chain     []*ChainConfig     `protobuf:"bytes,1,rep,name=chain,proto3" json:"chain,omitempty"`
	Lightning []*LightningConfig `protobuf:"bytes,2,rep,name=lightning,proto3" json:"lightning,omitempty"`
	// contains filtered or unexported fields
}

func (*Config) Descriptor deprecated 

func (*Config) Descriptor() ([]byte, []int)

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetChain 

func (x *Config) GetChain() []*ChainConfig

func (*Config) GetLightning 

func (x *Config) GetLightning() []*LightningConfig

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect 

func (x *Config) ProtoReflect() protoreflect.Message

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) String 

func (x *Config) String() string

type ExecuteRecommendationsRequest 

type ExecuteRecommendationsRequest struct {
	Lightning []*LightningRecommendation `protobuf:"bytes,1,rep,name=lightning,proto3" json:"lightning,omitempty"`
	Chain     []*ChainRecommendation     `protobuf:"bytes,2,rep,name=chain,proto3" json:"chain,omitempty"`
	// Forcefully execute all recommendations, even ones that have dismissal reasons.
	Force *bool `protobuf:"varint,3,opt,name=force,proto3,oneof" json:"force,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteRecommendationsRequest) Descriptor deprecated 

func (*ExecuteRecommendationsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteRecommendationsRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRecommendationsRequest) GetChain 

func (x *ExecuteRecommendationsRequest) GetChain() []*ChainRecommendation

func (*ExecuteRecommendationsRequest) GetForce 

func (x *ExecuteRecommendationsRequest) GetForce() bool

func (*ExecuteRecommendationsRequest) GetLightning 

func (x *ExecuteRecommendationsRequest) GetLightning() []*LightningRecommendation

func (*ExecuteRecommendationsRequest) ProtoMessage 

func (*ExecuteRecommendationsRequest) ProtoMessage()

func (*ExecuteRecommendationsRequest) ProtoReflect 

func (x *ExecuteRecommendationsRequest) ProtoReflect() protoreflect.Message

func (*ExecuteRecommendationsRequest) Reset 

func (x *ExecuteRecommendationsRequest) Reset()

func (*ExecuteRecommendationsRequest) String 

func (x *ExecuteRecommendationsRequest) String() string

type ExecuteRecommendationsResponse 

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

func (*ExecuteRecommendationsResponse) Descriptor deprecated 

func (*ExecuteRecommendationsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteRecommendationsResponse.ProtoReflect.Descriptor instead.

func (*ExecuteRecommendationsResponse) ProtoMessage 

func (*ExecuteRecommendationsResponse) ProtoMessage()

func (*ExecuteRecommendationsResponse) ProtoReflect 

func (x *ExecuteRecommendationsResponse) ProtoReflect() protoreflect.Message

func (*ExecuteRecommendationsResponse) Reset 

func (x *ExecuteRecommendationsResponse) Reset()

func (*ExecuteRecommendationsResponse) String 

func (x *ExecuteRecommendationsResponse) String() string

type GetConfigRequest 

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

func (*GetConfigRequest) Descriptor deprecated 

func (*GetConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetConfigRequest.ProtoReflect.Descriptor instead.

func (*GetConfigRequest) ProtoMessage 

func (*GetConfigRequest) ProtoMessage()

func (*GetConfigRequest) ProtoReflect 

func (x *GetConfigRequest) ProtoReflect() protoreflect.Message

func (*GetConfigRequest) Reset 

func (x *GetConfigRequest) Reset()

func (*GetConfigRequest) String 

func (x *GetConfigRequest) String() string

type GetRecommendationsRequest 

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

func (*GetRecommendationsRequest) Descriptor deprecated 

func (*GetRecommendationsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRecommendationsRequest.ProtoReflect.Descriptor instead.

func (*GetRecommendationsRequest) ProtoMessage 

func (*GetRecommendationsRequest) ProtoMessage()

func (*GetRecommendationsRequest) ProtoReflect 

func (x *GetRecommendationsRequest) ProtoReflect() protoreflect.Message

func (*GetRecommendationsRequest) Reset 

func (x *GetRecommendationsRequest) Reset()

func (*GetRecommendationsRequest) String 

func (x *GetRecommendationsRequest) String() string

type GetRecommendationsResponse 

type GetRecommendationsResponse struct {
	Lightning []*LightningRecommendation `protobuf:"bytes,1,rep,name=lightning,proto3" json:"lightning,omitempty"`
	Chain     []*ChainRecommendation     `protobuf:"bytes,2,rep,name=chain,proto3" json:"chain,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRecommendationsResponse) Descriptor deprecated 

func (*GetRecommendationsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetRecommendationsResponse.ProtoReflect.Descriptor instead.

func (*GetRecommendationsResponse) GetChain 

func (x *GetRecommendationsResponse) GetChain() []*ChainRecommendation

func (*GetRecommendationsResponse) GetLightning 

func (x *GetRecommendationsResponse) GetLightning() []*LightningRecommendation

func (*GetRecommendationsResponse) ProtoMessage 

func (*GetRecommendationsResponse) ProtoMessage()

func (*GetRecommendationsResponse) ProtoReflect 

func (x *GetRecommendationsResponse) ProtoReflect() protoreflect.Message

func (*GetRecommendationsResponse) Reset 

func (x *GetRecommendationsResponse) Reset()

func (*GetRecommendationsResponse) String 

func (x *GetRecommendationsResponse) String() string

type GetStatusRequest 

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

func (*GetStatusRequest) Descriptor deprecated 

func (*GetStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetStatusRequest.ProtoReflect.Descriptor instead.

func (*GetStatusRequest) ProtoMessage 

func (*GetStatusRequest) ProtoMessage()

func (*GetStatusRequest) ProtoReflect 

func (x *GetStatusRequest) ProtoReflect() protoreflect.Message

func (*GetStatusRequest) Reset 

func (x *GetStatusRequest) Reset()

func (*GetStatusRequest) String 

func (x *GetStatusRequest) String() string

type GetStatusResponse 

type GetStatusResponse struct {
	Lightning *Status `protobuf:"bytes,1,opt,name=lightning,proto3,oneof" json:"lightning,omitempty"`
	Chain     *Status `protobuf:"bytes,2,opt,name=chain,proto3,oneof" json:"chain,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatusResponse) Descriptor deprecated 

func (*GetStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetStatusResponse.ProtoReflect.Descriptor instead.

func (*GetStatusResponse) GetChain 

func (x *GetStatusResponse) GetChain() *Status

func (*GetStatusResponse) GetLightning 

func (x *GetStatusResponse) GetLightning() *Status

func (*GetStatusResponse) ProtoMessage 

func (*GetStatusResponse) ProtoMessage()

func (*GetStatusResponse) ProtoReflect 

func (x *GetStatusResponse) ProtoReflect() protoreflect.Message

func (*GetStatusResponse) Reset 

func (x *GetStatusResponse) Reset()

func (*GetStatusResponse) String 

func (x *GetStatusResponse) String() string

type LightningConfig 

type LightningConfig struct {
	Enabled                bool              `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	ChannelPollInterval    uint64            `protobuf:"varint,2,opt,name=channel_poll_interval,json=channelPollInterval,proto3" json:"channel_poll_interval,omitempty"`
	StaticAddress          string            `protobuf:"bytes,3,opt,name=static_address,json=staticAddress,proto3" json:"static_address,omitempty"`
	OutboundBalance        uint64            `protobuf:"varint,4,opt,name=outbound_balance,json=outboundBalance,proto3" json:"outbound_balance,omitempty"`
	InboundBalance         uint64            `protobuf:"varint,5,opt,name=inbound_balance,json=inboundBalance,proto3" json:"inbound_balance,omitempty"`
	OutboundBalancePercent float32           `` /* 131-byte string literal not displayed */
	InboundBalancePercent  float32           `` /* 128-byte string literal not displayed */
	MaxFeePercent          float32           `protobuf:"fixed32,8,opt,name=max_fee_percent,json=maxFeePercent,proto3" json:"max_fee_percent,omitempty"`
	AcceptZeroConf         bool              `protobuf:"varint,9,opt,name=accept_zero_conf,json=acceptZeroConf,proto3" json:"accept_zero_conf,omitempty"`
	FailureBackoff         uint64            `protobuf:"varint,10,opt,name=failure_backoff,json=failureBackoff,proto3" json:"failure_backoff,omitempty"`
	Budget                 uint64            `protobuf:"varint,11,opt,name=budget,proto3" json:"budget,omitempty"`
	BudgetInterval         uint64            `protobuf:"varint,12,opt,name=budget_interval,json=budgetInterval,proto3" json:"budget_interval,omitempty"`
	Currency               boltzrpc.Currency `protobuf:"varint,13,opt,name=currency,proto3,enum=boltzrpc.Currency" json:"currency,omitempty"`
	SwapType               string            `protobuf:"bytes,14,opt,name=swap_type,json=swapType,proto3" json:"swap_type,omitempty"`
	PerChannel             bool              `protobuf:"varint,15,opt,name=per_channel,json=perChannel,proto3" json:"per_channel,omitempty"`
	Wallet                 string            `protobuf:"bytes,16,opt,name=wallet,proto3" json:"wallet,omitempty"`
	MaxSwapAmount          uint64            `protobuf:"varint,17,opt,name=max_swap_amount,json=maxSwapAmount,proto3" json:"max_swap_amount,omitempty"`
	Tenant                 *string           `protobuf:"bytes,18,opt,name=tenant,proto3,oneof" json:"tenant,omitempty"`
	// contains filtered or unexported fields
}

func (*LightningConfig) Descriptor deprecated 

func (*LightningConfig) Descriptor() ([]byte, []int)

Deprecated: Use LightningConfig.ProtoReflect.Descriptor instead.

func (*LightningConfig) GetAcceptZeroConf 

func (x *LightningConfig) GetAcceptZeroConf() bool

func (*LightningConfig) GetBudget 

func (x *LightningConfig) GetBudget() uint64

func (*LightningConfig) GetBudgetInterval 

func (x *LightningConfig) GetBudgetInterval() uint64

func (*LightningConfig) GetChannelPollInterval 

func (x *LightningConfig) GetChannelPollInterval() uint64

func (*LightningConfig) GetCurrency 

func (x *LightningConfig) GetCurrency() boltzrpc.Currency

func (*LightningConfig) GetEnabled 

func (x *LightningConfig) GetEnabled() bool

func (*LightningConfig) GetFailureBackoff 

func (x *LightningConfig) GetFailureBackoff() uint64

func (*LightningConfig) GetInboundBalance 

func (x *LightningConfig) GetInboundBalance() uint64

func (*LightningConfig) GetInboundBalancePercent 

func (x *LightningConfig) GetInboundBalancePercent() float32

func (*LightningConfig) GetMaxFeePercent 

func (x *LightningConfig) GetMaxFeePercent() float32

func (*LightningConfig) GetMaxSwapAmount 

func (x *LightningConfig) GetMaxSwapAmount() uint64

func (*LightningConfig) GetOutboundBalance 

func (x *LightningConfig) GetOutboundBalance() uint64

func (*LightningConfig) GetOutboundBalancePercent 

func (x *LightningConfig) GetOutboundBalancePercent() float32

func (*LightningConfig) GetPerChannel 

func (x *LightningConfig) GetPerChannel() bool

func (*LightningConfig) GetStaticAddress 

func (x *LightningConfig) GetStaticAddress() string

func (*LightningConfig) GetSwapType 

func (x *LightningConfig) GetSwapType() string

func (*LightningConfig) GetTenant 

func (x *LightningConfig) GetTenant() string

func (*LightningConfig) GetWallet 

func (x *LightningConfig) GetWallet() string

func (*LightningConfig) ProtoMessage 

func (*LightningConfig) ProtoMessage()

func (*LightningConfig) ProtoReflect 

func (x *LightningConfig) ProtoReflect() protoreflect.Message

func (*LightningConfig) Reset 

func (x *LightningConfig) Reset()

func (*LightningConfig) String 

func (x *LightningConfig) String() string

type LightningRecommendation 

type LightningRecommendation struct {

	// Populated when a swap is recommended for the associated `channel`,
	// otherwise, the current balances are below the configured thresholds
	Swap    *LightningSwap             `protobuf:"bytes,1,opt,name=swap,proto3,oneof" json:"swap,omitempty"`
	Channel *boltzrpc.LightningChannel `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	// the thresholds for a swap to be recommended for the `channel`
	Thresholds *LightningThresholds `protobuf:"bytes,3,opt,name=thresholds,proto3" json:"thresholds,omitempty"`
	// contains filtered or unexported fields
}

func (*LightningRecommendation) Descriptor deprecated 

func (*LightningRecommendation) Descriptor() ([]byte, []int)

Deprecated: Use LightningRecommendation.ProtoReflect.Descriptor instead.

func (*LightningRecommendation) GetChannel 

func (x *LightningRecommendation) GetChannel() *boltzrpc.LightningChannel

func (*LightningRecommendation) GetSwap 

func (x *LightningRecommendation) GetSwap() *LightningSwap

func (*LightningRecommendation) GetThresholds 

func (x *LightningRecommendation) GetThresholds() *LightningThresholds

func (*LightningRecommendation) ProtoMessage 

func (*LightningRecommendation) ProtoMessage()

func (*LightningRecommendation) ProtoReflect 

func (x *LightningRecommendation) ProtoReflect() protoreflect.Message

func (*LightningRecommendation) Reset 

func (x *LightningRecommendation) Reset()

func (*LightningRecommendation) String 

func (x *LightningRecommendation) String() string

type LightningSwap 

type LightningSwap struct {
	Amount      uint64            `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty"`
	FeeEstimate uint64            `protobuf:"varint,2,opt,name=fee_estimate,json=feeEstimate,proto3" json:"fee_estimate,omitempty"`
	Type        boltzrpc.SwapType `protobuf:"varint,3,opt,name=type,proto3,enum=boltzrpc.SwapType" json:"type,omitempty"`
	// Reasons for which the swap is not being executed
	DismissedReasons []string `protobuf:"bytes,4,rep,name=dismissed_reasons,json=dismissedReasons,proto3" json:"dismissed_reasons,omitempty"`
	// contains filtered or unexported fields
}

func (*LightningSwap) Descriptor deprecated 

func (*LightningSwap) Descriptor() ([]byte, []int)

Deprecated: Use LightningSwap.ProtoReflect.Descriptor instead.

func (*LightningSwap) GetAmount 

func (x *LightningSwap) GetAmount() uint64

func (*LightningSwap) GetDismissedReasons 

func (x *LightningSwap) GetDismissedReasons() []string

func (*LightningSwap) GetFeeEstimate 

func (x *LightningSwap) GetFeeEstimate() uint64

func (*LightningSwap) GetType 

func (x *LightningSwap) GetType() boltzrpc.SwapType

func (*LightningSwap) ProtoMessage 

func (*LightningSwap) ProtoMessage()

func (*LightningSwap) ProtoReflect 

func (x *LightningSwap) ProtoReflect() protoreflect.Message

func (*LightningSwap) Reset 

func (x *LightningSwap) Reset()

func (*LightningSwap) String 

func (x *LightningSwap) String() string

type LightningThresholds 

type LightningThresholds struct {
	Inbound  *uint64 `protobuf:"varint,1,opt,name=inbound,proto3,oneof" json:"inbound,omitempty"`
	Outbound *uint64 `protobuf:"varint,2,opt,name=outbound,proto3,oneof" json:"outbound,omitempty"`
	// contains filtered or unexported fields
}

func (*LightningThresholds) Descriptor deprecated 

func (*LightningThresholds) Descriptor() ([]byte, []int)

Deprecated: Use LightningThresholds.ProtoReflect.Descriptor instead.

func (*LightningThresholds) GetInbound 

func (x *LightningThresholds) GetInbound() uint64

func (*LightningThresholds) GetOutbound 

func (x *LightningThresholds) GetOutbound() uint64

func (*LightningThresholds) ProtoMessage 

func (*LightningThresholds) ProtoMessage()

func (*LightningThresholds) ProtoReflect 

func (x *LightningThresholds) ProtoReflect() protoreflect.Message

func (*LightningThresholds) Reset 

func (x *LightningThresholds) Reset()

func (*LightningThresholds) String 

func (x *LightningThresholds) String() string

type Status 

type Status struct {
	Running     bool    `protobuf:"varint,1,opt,name=running,proto3" json:"running,omitempty"`
	Error       *string `protobuf:"bytes,2,opt,name=error,proto3,oneof" json:"error,omitempty"`
	Budget      *Budget `protobuf:"bytes,3,opt,name=budget,proto3,oneof" json:"budget,omitempty"`
	Description string  `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

func (*Status) Descriptor() ([]byte, []int)

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetBudget 

func (x *Status) GetBudget() *Budget

func (*Status) GetDescription 

func (x *Status) GetDescription() string

func (*Status) GetError 

func (x *Status) GetError() string

func (*Status) GetRunning 

func (x *Status) GetRunning() bool

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

func (x *Status) ProtoReflect() protoreflect.Message

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type UnimplementedAutoSwapServer 

type UnimplementedAutoSwapServer struct {
}

UnimplementedAutoSwapServer must be embedded to have forward compatible implementations.

func (UnimplementedAutoSwapServer) ExecuteRecommendations 

func (UnimplementedAutoSwapServer) ExecuteRecommendations(context.Context, *ExecuteRecommendationsRequest) (*ExecuteRecommendationsResponse, error)

func (UnimplementedAutoSwapServer) GetConfig 

func (UnimplementedAutoSwapServer) GetConfig(context.Context, *GetConfigRequest) (*Config, error)

func (UnimplementedAutoSwapServer) GetRecommendations 

func (UnimplementedAutoSwapServer) GetRecommendations(context.Context, *GetRecommendationsRequest) (*GetRecommendationsResponse, error)

func (UnimplementedAutoSwapServer) GetStatus 

func (UnimplementedAutoSwapServer) GetStatus(context.Context, *GetStatusRequest) (*GetStatusResponse, error)

func (UnimplementedAutoSwapServer) ReloadConfig 

func (UnimplementedAutoSwapServer) ReloadConfig(context.Context, *empty.Empty) (*Config, error)

func (UnimplementedAutoSwapServer) UpdateChainConfig 

func (UnimplementedAutoSwapServer) UpdateChainConfig(context.Context, *UpdateChainConfigRequest) (*Config, error)

func (UnimplementedAutoSwapServer) UpdateLightningConfig 

func (UnimplementedAutoSwapServer) UpdateLightningConfig(context.Context, *UpdateLightningConfigRequest) (*Config, error)

type UnsafeAutoSwapServer 

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

UnsafeAutoSwapServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AutoSwapServer will result in compilation errors.

type UpdateChainConfigRequest 

type UpdateChainConfigRequest struct {
	Config    *ChainConfig          `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	FieldMask *field_mask.FieldMask `protobuf:"bytes,2,opt,name=field_mask,json=fieldMask,proto3,oneof" json:"field_mask,omitempty"`
	Reset_    *bool                 `protobuf:"varint,3,opt,name=reset,proto3,oneof" json:"reset,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateChainConfigRequest) Descriptor deprecated 

func (*UpdateChainConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateChainConfigRequest.ProtoReflect.Descriptor instead.

func (*UpdateChainConfigRequest) GetConfig 

func (x *UpdateChainConfigRequest) GetConfig() *ChainConfig

func (*UpdateChainConfigRequest) GetFieldMask 

func (x *UpdateChainConfigRequest) GetFieldMask() *field_mask.FieldMask

func (*UpdateChainConfigRequest) GetReset_ 

func (x *UpdateChainConfigRequest) GetReset_() bool

func (*UpdateChainConfigRequest) ProtoMessage 

func (*UpdateChainConfigRequest) ProtoMessage()

func (*UpdateChainConfigRequest) ProtoReflect 

func (x *UpdateChainConfigRequest) ProtoReflect() protoreflect.Message

func (*UpdateChainConfigRequest) Reset 

func (x *UpdateChainConfigRequest) Reset()

func (*UpdateChainConfigRequest) String 

func (x *UpdateChainConfigRequest) String() string

type UpdateLightningConfigRequest 

type UpdateLightningConfigRequest struct {
	Config    *LightningConfig      `protobuf:"bytes,1,opt,name=config,proto3,oneof" json:"config,omitempty"`
	FieldMask *field_mask.FieldMask `protobuf:"bytes,2,opt,name=field_mask,json=fieldMask,proto3" json:"field_mask,omitempty"`
	Reset_    *bool                 `protobuf:"varint,3,opt,name=reset,proto3,oneof" json:"reset,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateLightningConfigRequest) Descriptor deprecated 

func (*UpdateLightningConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateLightningConfigRequest.ProtoReflect.Descriptor instead.

func (*UpdateLightningConfigRequest) GetConfig 

func (x *UpdateLightningConfigRequest) GetConfig() *LightningConfig

func (*UpdateLightningConfigRequest) GetFieldMask 

func (x *UpdateLightningConfigRequest) GetFieldMask() *field_mask.FieldMask

func (*UpdateLightningConfigRequest) GetReset_ 

func (x *UpdateLightningConfigRequest) GetReset_() bool

func (*UpdateLightningConfigRequest) ProtoMessage 

func (*UpdateLightningConfigRequest) ProtoMessage()

func (*UpdateLightningConfigRequest) ProtoReflect 

func (x *UpdateLightningConfigRequest) ProtoReflect() protoreflect.Message

func (*UpdateLightningConfigRequest) Reset 

func (x *UpdateLightningConfigRequest) Reset()

func (*UpdateLightningConfigRequest) String 

func (x *UpdateLightningConfigRequest) String() string

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.