gossip

Documentation

Index

• func RegisterGossipServer(s *grpc.Server, srv GossipServer)
• type Block
  • func (*Block) Descriptor() ([]byte, []int)
  • func (m *Block) GetBunch() []*EndorsedTx
  • func (m *Block) GetOffSet() string
  • func (m *Block) GetSign() string
  • func (*Block) ProtoMessage()
  • func (m *Block) Reset()
  • func (m *Block) String() string
  • func (m *Block) XXX_DiscardUnknown()
  • func (m *Block) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Block) XXX_Merge(src proto.Message)
  • func (m *Block) XXX_Size() int
  • func (m *Block) XXX_Unmarshal(b []byte) error
• type EndorsedTx
  • func (*EndorsedTx) Descriptor() ([]byte, []int)
  • func (m *EndorsedTx) GetPayload() []byte
  • func (m *EndorsedTx) GetSign() []string
  • func (m *EndorsedTx) GetTimeStamp() string
  • func (*EndorsedTx) ProtoMessage()
  • func (m *EndorsedTx) Reset()
  • func (m *EndorsedTx) String() string
  • func (m *EndorsedTx) XXX_DiscardUnknown()
  • func (m *EndorsedTx) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *EndorsedTx) XXX_Merge(src proto.Message)
  • func (m *EndorsedTx) XXX_Size() int
  • func (m *EndorsedTx) XXX_Unmarshal(b []byte) error
• type GossipClient
  • func NewGossipClient(cc *grpc.ClientConn) GossipClient
• type GossipServer

Functions

func RegisterGossipServer

func RegisterGossipServer(s *grpc.Server, srv GossipServer)

Types

type Block

type Block struct {
	Bunch                []*EndorsedTx `protobuf:"bytes,1,rep,name=bunch,proto3" json:"bunch,omitempty"`
	Sign                 string        `protobuf:"bytes,2,opt,name=Sign,proto3" json:"Sign,omitempty"`
	OffSet               string        `protobuf:"bytes,3,opt,name=OffSet,proto3" json:"OffSet,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*Block) Descriptor

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

func (*Block) GetBunch

func (m *Block) GetBunch() []*EndorsedTx

func (*Block) GetOffSet

func (m *Block) GetOffSet() string

func (*Block) GetSign

func (m *Block) GetSign() string

func (*Block) ProtoMessage

func (*Block) ProtoMessage()

func (*Block) Reset

func (m *Block) Reset()

func (*Block) String

func (m *Block) String() string

func (*Block) XXX_DiscardUnknown

func (m *Block) XXX_DiscardUnknown()

func (*Block) XXX_Marshal

func (m *Block) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Block) XXX_Merge

func (m *Block) XXX_Merge(src proto.Message)

func (*Block) XXX_Size

func (m *Block) XXX_Size() int

func (*Block) XXX_Unmarshal

func (m *Block) XXX_Unmarshal(b []byte) error

type EndorsedTx

type EndorsedTx struct {
	Sign                 []string `protobuf:"bytes,1,rep,name=Sign,proto3" json:"Sign,omitempty"`
	Payload              []byte   `protobuf:"bytes,2,opt,name=Payload,proto3" json:"Payload,omitempty"`
	TimeStamp            string   `protobuf:"bytes,3,opt,name=timeStamp,proto3" json:"timeStamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EndorsedTx) Descriptor

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

func (*EndorsedTx) GetPayload

func (m *EndorsedTx) GetPayload() []byte

func (*EndorsedTx) GetSign

func (m *EndorsedTx) GetSign() []string

func (*EndorsedTx) GetTimeStamp

func (m *EndorsedTx) GetTimeStamp() string

func (*EndorsedTx) ProtoMessage

func (*EndorsedTx) ProtoMessage()

func (*EndorsedTx) Reset

func (m *EndorsedTx) Reset()

func (*EndorsedTx) String

func (m *EndorsedTx) String() string

func (*EndorsedTx) XXX_DiscardUnknown

func (m *EndorsedTx) XXX_DiscardUnknown()

func (*EndorsedTx) XXX_Marshal

func (m *EndorsedTx) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndorsedTx) XXX_Merge

func (m *EndorsedTx) XXX_Merge(src proto.Message)

func (*EndorsedTx) XXX_Size

func (m *EndorsedTx) XXX_Size() int

func (*EndorsedTx) XXX_Unmarshal

func (m *EndorsedTx) XXX_Unmarshal(b []byte) error

type GossipClient

type GossipClient interface {
	Deliver(ctx context.Context, in *Block, opts ...grpc.CallOption) (*empty.Empty, error)
}

GossipClient is the client API for Gossip service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewGossipClient

func NewGossipClient(cc *grpc.ClientConn) GossipClient

type GossipServer

type GossipServer interface {
	Deliver(context.Context, *Block) (*empty.Empty, error)
}

GossipServer is the server API for Gossip service.