adminsvc

Oct 1, 2024

Changes in this version

+ type P2P interface

+ AddAndPersistPeer func(ctx context.Context, nodeID string) error

+ ListPeers func(ctx context.Context) []string

+ RemovePersistedPeer func(ctx context.Context, nodeID string) error

+ type Pricer interface

+ Price func(ctx context.Context, db sql.DB, tx *transactions.Transaction) (*big.Int, error)

type Service

+ func (svc *Service) AddPeer(ctx context.Context, req *adminjson.PeerRequest) (*adminjson.PeerResponse, *jsonrpc.Error)

+ func (svc *Service) ApproveResolution(ctx context.Context, req *adminjson.ApproveResolutionRequest) (*userjson.BroadcastResponse, *jsonrpc.Error)

+ func (svc *Service) CreateResolution(ctx context.Context, req *adminjson.CreateResolutionRequest) (*userjson.BroadcastResponse, *jsonrpc.Error)

+ func (svc *Service) Health(ctx context.Context) (json.RawMessage, bool)

+ func (svc *Service) HealthMethod(ctx context.Context, _ *userjson.HealthRequest) (*adminjson.HealthResponse, *jsonrpc.Error)

+ func (svc *Service) ListPeers(ctx context.Context, req *adminjson.PeersRequest) (*adminjson.ListPeersResponse, *jsonrpc.Error)

+ func (svc *Service) Name() string

+ func (svc *Service) RemovePeer(ctx context.Context, req *adminjson.PeerRequest) (*adminjson.PeerResponse, *jsonrpc.Error)

+ func (svc *Service) ResolutionStatus(ctx context.Context, req *adminjson.ResolutionStatusRequest) (*adminjson.ResolutionStatusResponse, *jsonrpc.Error)

Jun 11, 2024

Changes in this version

+ var SpecInfo = openrpc.Info

+ type BlockchainTransactor interface

+ BroadcastTx func(ctx context.Context, tx []byte, sync uint8) (*cmtCoreTypes.ResultBroadcastTx, error)

+ Peers func(context.Context) ([]*types.PeerInfo, error)

+ Status func(context.Context) (*types.Status, error)

+ type Service struct

+ TxApp TxApp

+ func NewService(db sql.ReadTxMaker, blockchain BlockchainTransactor, txApp TxApp, ...) *Service

+ func (svc *Service) Approve(ctx context.Context, req *adminjson.ApproveRequest) (*userjson.BroadcastResponse, *jsonrpc.Error)

+ func (svc *Service) GetConfig(ctx context.Context, req *adminjson.GetConfigRequest) (*adminjson.GetConfigResponse, *jsonrpc.Error)

+ func (svc *Service) Handlers() map[jsonrpc.Method]rpcserver.MethodHandler

+ func (svc *Service) Join(ctx context.Context, req *adminjson.JoinRequest) (*userjson.BroadcastResponse, *jsonrpc.Error)

+ func (svc *Service) JoinStatus(ctx context.Context, req *adminjson.JoinStatusRequest) (*adminjson.JoinStatusResponse, *jsonrpc.Error)

+ func (svc *Service) Leave(ctx context.Context, req *adminjson.LeaveRequest) (*userjson.BroadcastResponse, *jsonrpc.Error)

+ func (svc *Service) ListPendingJoins(ctx context.Context, req *adminjson.ListJoinRequestsRequest) (*adminjson.ListJoinRequestsResponse, *jsonrpc.Error)

+ func (svc *Service) ListValidators(ctx context.Context, req *adminjson.ListValidatorsRequest) (*adminjson.ListValidatorsResponse, *jsonrpc.Error)

+ func (svc *Service) Methods() map[jsonrpc.Method]rpcserver.MethodDef

+ func (svc *Service) Peers(ctx context.Context, _ *adminjson.PeersRequest) (*adminjson.PeersResponse, *jsonrpc.Error)

+ func (svc *Service) Remove(ctx context.Context, req *adminjson.RemoveRequest) (*userjson.BroadcastResponse, *jsonrpc.Error)

+ func (svc *Service) Status(ctx context.Context, req *adminjson.StatusRequest) (*adminjson.StatusResponse, *jsonrpc.Error)

+ type TxApp interface

+ AccountInfo func(ctx context.Context, identifier []byte, unconfirmed bool) (balance *big.Int, nonce int64, err error)

+ Price func(ctx context.Context, tx *transactions.Transaction) (*big.Int, error)