peers

type AddressIDReceiver interface {
	AddressID(multiaddr.Multiaddr) (ID, error)
}

type GRPCConnector interface {
	GRPCConnection(ctx context.Context, maddr multiaddr.Multiaddr, reset bool) (*grpc.ClientConn, error)
}

type GreeterClient interface {
	Hello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error)
}

type GreeterServer interface {
	Hello(context.Context, *HelloRequest) (*HelloResponse, error)
}

type HelloRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type HelloResponse struct {
	Message              string   `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type ID string

type Interface interface {
	Shutdown() error
	Job(context.Context)
	Address() multiaddr.Multiaddr
	RemoveConnection(maddr multiaddr.Multiaddr) error
	Listen(maddr multiaddr.Multiaddr) (manet.Listener, error)
	Connect(ctx context.Context, maddr multiaddr.Multiaddr) (manet.Conn, error)
	GRPCConnector
}

type Params struct {
	Address          multiaddr.Multiaddr
	Transport        transport.Transport
	Logger           *zap.Logger
	Attempts         int64
	AttemptsTTL      time.Duration
	ConnectionTTL    time.Duration
	ConnectionIDLE   time.Duration
	MetricsTimeout   time.Duration
	KeepAliveTTL     time.Duration
	KeepAlivePingTTL time.Duration
}

type Peer interface {
	ID() ID
	Address() multiaddr.Multiaddr
	PublicKey() *ecdsa.PublicKey
	PrivateKey() (*ecdsa.PrivateKey, error)
	SetPrivateKey(*ecdsa.PrivateKey) error
}

type PeerFilter func(Peer) bool

type PeerNetAddressStore interface {
	GetAddr(ID) (multiaddr.Multiaddr, error)
}

type PublicKeyStore interface {
	GetPublicKey(ID) (*ecdsa.PublicKey, error)
}

type SelfIDReceiver interface {
	SelfID() ID
}

type Storage interface {
	Get(ID) (Peer, error)
	Set(ID, Peer) error
	Has(ID) bool
	Rem(ID) error
	List(ID, int64, int) ([]ID, error)
	Filter(PeerFilter) []ID
	Update(*netmap.NetMap) error
}

type Store interface {
	SelfIDReceiver
	PublicKeyStore
	AddressIDReceiver
	AddPeer(multiaddr.Multiaddr, *ecdsa.PublicKey, *ecdsa.PrivateKey) (ID, error)
	DeletePeer(ID)
	PeerNetAddressStore
	GetPrivateKey(ID) (*ecdsa.PrivateKey, error)
	Update(*netmap.NetMap) error
	Sign([]byte) ([]byte, error)
	Verify(id ID, data, sign []byte) error
	Check(min int) error
}

type StoreParams struct {
	Addr     multiaddr.Multiaddr
	Key      *ecdsa.PrivateKey
	Storage  Storage
	StoreCap int
	Logger   *zap.Logger
}

type UnimplementedGreeterServer struct {
}