gossip

type Ack struct {
	Error string `protobuf:"bytes,1,opt,name=Error,proto3" json:"Error,omitempty"`
	// contains filtered or unexported fields
}

type Fingerprint [16]byte

type FingerprintDigest func(msg *GossipMsg) Fingerprint

type GossipClient interface {
	Endpoint(ctx context.Context, in *GossipMsg, opts ...grpc.CallOption) (*Ack, error)
	Stream(ctx context.Context, opts ...grpc.CallOption) (Gossip_StreamClient, error)
}

type GossipMsg struct {
	Tag       string `protobuf:"bytes,1,opt,name=Tag,proto3" json:"Tag,omitempty"`
	Origin    []byte `protobuf:"bytes,2,opt,name=Origin,proto3" json:"Origin,omitempty"`
	Payload   []byte `protobuf:"bytes,3,opt,name=Payload,proto3" json:"Payload,omitempty"`
	Signature []byte `protobuf:"bytes,4,opt,name=Signature,proto3" json:"Signature,omitempty"`
	Timestamp int64  `protobuf:"varint,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type GossipServer interface {
	Endpoint(context.Context, *GossipMsg) (*Ack, error)
	Stream(Gossip_StreamServer) error
	// contains filtered or unexported methods
}

type Gossip_StreamClient interface {
	Send(*GossipMsg) error
	CloseAndRecv() (*Ack, error)
	grpc.ClientStream
}

type Gossip_StreamServer interface {
	SendAndClose(*Ack) error
	Recv() (*GossipMsg, error)
	grpc.ServerStream
}

type Manager struct {
	*UnimplementedGossipServer
	// contains filtered or unexported fields
}

type ManagerFlags struct {
	// How long a message record should last in the buffer
	BufferExpirationTime time.Duration

	// Frequency with which to check the buffer.
	// Should be long, since the thread takes a lock each time it checks the buffer
	MonitorThreadFrequency time.Duration
}

type MessageRecord struct {
	Timestamp time.Time
	Messages  []*GossipMsg
}

type Protocol struct {

	// Marks a Protocol as Defunct such that it will ignore new messages
	IsDefunct bool
	// contains filtered or unexported fields
}

type ProtocolFlags struct {
	FanOut                  uint8         // Default = 0
	MaxRecordedFingerprints uint64        // Default = 10000000
	MaximumReSends          uint64        // Default = 3
	NumParallelSends        uint32        // Default = 5
	MaxGossipAge            time.Duration // Default = 10 * time.Second
	SelfGossip              bool          // Default = false
	Fingerprinter           FingerprintDigest
}

type Receiver func(*GossipMsg) error

type SignatureVerification func(*GossipMsg, []byte) error

type UnimplementedGossipServer struct {
}

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