core

package

v0.0.0-...-2dd5fde Latest Latest Go to latest Published: May 2, 2019 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rajdhamsaniya/consensus

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func RegisterPeerManagerServer(s *grpc.Server, srv PeerManagerServer)
type ExecResponse
type Executetx
type Executetx_InvokerType
- func (Executetx_InvokerType) EnumDescriptor() ([]byte, []int)
- func (x Executetx_InvokerType) String() string
type PeerManagerClient
- func NewPeerManagerClient(cc *grpc.ClientConn) PeerManagerClient
type PeerManagerServer

Constants ¶

This section is empty.

Variables ¶

View Source

var Executetx_InvokerType_name = map[int32]string{
	0: "CLIENT",
	1: "PEER",
}

View Source

var Executetx_InvokerType_value = map[string]int32{
	"CLIENT": 0,
	"PEER":   1,
}

Functions ¶

func RegisterPeerManagerServer ¶

func RegisterPeerManagerServer(s *grpc.Server, srv PeerManagerServer)

Types ¶

type ExecResponse ¶

type ExecResponse struct {
	Sign                 string   `protobuf:"bytes,1,opt,name=Sign,proto3" json:"Sign,omitempty"`
	Result               []byte   `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExecResponse) Descriptor ¶

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

func (*ExecResponse) GetResult ¶

func (m *ExecResponse) GetResult() []byte

func (*ExecResponse) GetSign ¶

func (m *ExecResponse) GetSign() string

func (*ExecResponse) ProtoMessage ¶

func (*ExecResponse) ProtoMessage()

func (*ExecResponse) Reset ¶

func (m *ExecResponse) Reset()

func (*ExecResponse) String ¶

func (m *ExecResponse) String() string

func (*ExecResponse) XXX_DiscardUnknown ¶

func (m *ExecResponse) XXX_DiscardUnknown()

func (*ExecResponse) XXX_Marshal ¶

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

func (*ExecResponse) XXX_Merge ¶

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

func (*ExecResponse) XXX_Size ¶

func (m *ExecResponse) XXX_Size() int

func (*ExecResponse) XXX_Unmarshal ¶

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

type Executetx ¶

type Executetx struct {
	Tx                   string                `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
	Args                 []string              `protobuf:"bytes,2,rep,name=Args,proto3" json:"Args,omitempty"`
	InvokerId            string                `protobuf:"bytes,3,opt,name=invokerId,proto3" json:"invokerId,omitempty"`
	IType                Executetx_InvokerType `protobuf:"varint,4,opt,name=iType,proto3,enum=core.Executetx_InvokerType" json:"iType,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Executetx) Descriptor ¶

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

func (*Executetx) GetArgs ¶

func (m *Executetx) GetArgs() []string

func (*Executetx) GetIType ¶

func (m *Executetx) GetIType() Executetx_InvokerType

func (*Executetx) GetInvokerId ¶

func (m *Executetx) GetInvokerId() string

func (*Executetx) GetTx ¶

func (m *Executetx) GetTx() string

func (*Executetx) ProtoMessage ¶

func (*Executetx) ProtoMessage()

func (*Executetx) Reset ¶

func (m *Executetx) Reset()

func (*Executetx) String ¶

func (m *Executetx) String() string

func (*Executetx) XXX_DiscardUnknown ¶

func (m *Executetx) XXX_DiscardUnknown()

func (*Executetx) XXX_Marshal ¶

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

func (*Executetx) XXX_Merge ¶

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

func (*Executetx) XXX_Size ¶

func (m *Executetx) XXX_Size() int

func (*Executetx) XXX_Unmarshal ¶

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

type Executetx_InvokerType ¶

type Executetx_InvokerType int32

const (
	Executetx_CLIENT Executetx_InvokerType = 0
	Executetx_PEER   Executetx_InvokerType = 1
)

func (Executetx_InvokerType) EnumDescriptor ¶

func (Executetx_InvokerType) EnumDescriptor() ([]byte, []int)

func (Executetx_InvokerType) String ¶

func (x Executetx_InvokerType) String() string

type PeerManagerClient ¶

type PeerManagerClient interface {
	InitContract(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ExecResponse, error)
	ExecuteTransaction(ctx context.Context, in *Executetx, opts ...grpc.CallOption) (*ExecResponse, error)
	ValidateBlock(ctx context.Context, in *gossip.Block, opts ...grpc.CallOption) (*empty.Empty, error)
}

PeerManagerClient is the client API for PeerManager service.

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

func NewPeerManagerClient ¶

func NewPeerManagerClient(cc *grpc.ClientConn) PeerManagerClient

type PeerManagerServer ¶

type PeerManagerServer interface {
	InitContract(context.Context, *empty.Empty) (*ExecResponse, error)
	ExecuteTransaction(context.Context, *Executetx) (*ExecResponse, error)
	ValidateBlock(context.Context, *gossip.Block) (*empty.Empty, error)
}

PeerManagerServer is the server API for PeerManager service.

Source Files ¶

View all Source files

core.pb.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL