chimera

package
v0.0.0-...-0ddf941 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 5, 2019 License: Apache-2.0 Imports: 14 Imported by: 2

Documentation

Overview

Package chimera is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterClientHandler 

func RegisterClientHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterClientHandler registers the http handlers for service Client to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterClientHandlerClient 

func RegisterClientHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ClientClient) error

RegisterClientHandlerClient registers the http handlers for service Client to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ClientClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ClientClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ClientClient" to call the correct interceptors.

func RegisterClientHandlerFromEndpoint 

func RegisterClientHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterClientHandlerFromEndpoint is same as RegisterClientHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterClientHandlerServer 

func RegisterClientHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ClientServer) error

RegisterClientHandlerServer registers the http handlers for service Client to "mux". UnaryRPC :call ClientServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterClientServer 

func RegisterClientServer(s *grpc.Server, srv ClientServer)

Types

type ApiVersion 

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

The Apiversion on which the server is running

func (*ApiVersion) Descriptor 

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

func (*ApiVersion) GetVersion 

func (m *ApiVersion) GetVersion() string

func (*ApiVersion) ProtoMessage 

func (*ApiVersion) ProtoMessage()

func (*ApiVersion) Reset 

func (m *ApiVersion) Reset()

func (*ApiVersion) String 

func (m *ApiVersion) String() string

func (*ApiVersion) XXX_DiscardUnknown 

func (m *ApiVersion) XXX_DiscardUnknown()

func (*ApiVersion) XXX_Marshal 

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

func (*ApiVersion) XXX_Merge 

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

func (*ApiVersion) XXX_Size 

func (m *ApiVersion) XXX_Size() int

func (*ApiVersion) XXX_Unmarshal 

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

type ClientClient 

type ClientClient interface {
	// Get version of the server running
	Version(ctx context.Context, in *ApiVersion, opts ...grpc.CallOption) (*ApiVersion, error)
	// Checks if the server is running
	Upcheck(ctx context.Context, in *UpCheckResponse, opts ...grpc.CallOption) (*UpCheckResponse, error)
	// Used to store a transaction in the Chimera node
	Send(ctx context.Context, in *SendRequest, opts ...grpc.CallOption) (*SendResponse, error)
	// Retrieve a transaction from the Chimera node
	Receive(ctx context.Context, in *ReceiveRequest, opts ...grpc.CallOption) (*ReceiveResponse, error)
	// Used to store a transaction locally
	StoreRaw(ctx context.Context, in *StoreRequest, opts ...grpc.CallOption) (*SendResponse, error)
	// Used to send signed transaction to the Chimera node
	SendSignedTx(ctx context.Context, in *SendSignedRequest, opts ...grpc.CallOption) (*SendResponse, error)
	// Used to get party info from Chimera node
	GetPartyInfo(ctx context.Context, in *PartyInfo, opts ...grpc.CallOption) (*PartyInfo, error)
	// Update the partyinfo with response from all the nodes connnected to the node
	UpdatePartyInfo(ctx context.Context, in *PartyInfo, opts ...grpc.CallOption) (*PartyInfoResponse, error)
	// Propogate payload to remote node
	Push(ctx context.Context, in *PushPayload, opts ...grpc.CallOption) (*PartyInfoResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteRequest, error)
	Resend(ctx context.Context, in *ResendRequest, opts ...grpc.CallOption) (*ResendResponse, error)
}

ClientClient is the client API for Client service.

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

func NewClientClient 

func NewClientClient(cc *grpc.ClientConn) ClientClient

type ClientServer 

type ClientServer interface {
	// Get version of the server running
	Version(context.Context, *ApiVersion) (*ApiVersion, error)
	// Checks if the server is running
	Upcheck(context.Context, *UpCheckResponse) (*UpCheckResponse, error)
	// Used to store a transaction in the Chimera node
	Send(context.Context, *SendRequest) (*SendResponse, error)
	// Retrieve a transaction from the Chimera node
	Receive(context.Context, *ReceiveRequest) (*ReceiveResponse, error)
	// Used to store a transaction locally
	StoreRaw(context.Context, *StoreRequest) (*SendResponse, error)
	// Used to send signed transaction to the Chimera node
	SendSignedTx(context.Context, *SendSignedRequest) (*SendResponse, error)
	// Used to get party info from Chimera node
	GetPartyInfo(context.Context, *PartyInfo) (*PartyInfo, error)
	// Update the partyinfo with response from all the nodes connnected to the node
	UpdatePartyInfo(context.Context, *PartyInfo) (*PartyInfoResponse, error)
	// Propogate payload to remote node
	Push(context.Context, *PushPayload) (*PartyInfoResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteRequest, error)
	Resend(context.Context, *ResendRequest) (*ResendResponse, error)
}

ClientServer is the server API for Client service.

type DeleteRequest 

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

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetKey 

func (m *DeleteRequest) GetKey() []byte

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

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

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type EncryptedPayload 

type EncryptedPayload struct {
	Sender               []byte   `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	CipherText           []byte   `protobuf:"bytes,2,opt,name=cipherText,proto3" json:"cipherText,omitempty"`
	Nonce                []byte   `protobuf:"bytes,3,opt,name=nonce,proto3" json:"nonce,omitempty"`
	ReciepientBoxes      [][]byte `protobuf:"bytes,4,rep,name=reciepientBoxes,proto3" json:"reciepientBoxes,omitempty"`
	ReciepientNonce      []byte   `protobuf:"bytes,5,opt,name=reciepientNonce,proto3" json:"reciepientNonce,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The Encrypted payload used to propogate the new transaction payload to other Chimera nodes

func (*EncryptedPayload) Descriptor 

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

func (*EncryptedPayload) GetCipherText 

func (m *EncryptedPayload) GetCipherText() []byte

func (*EncryptedPayload) GetNonce 

func (m *EncryptedPayload) GetNonce() []byte

func (*EncryptedPayload) GetReciepientBoxes 

func (m *EncryptedPayload) GetReciepientBoxes() [][]byte

func (*EncryptedPayload) GetReciepientNonce 

func (m *EncryptedPayload) GetReciepientNonce() []byte

func (*EncryptedPayload) GetSender 

func (m *EncryptedPayload) GetSender() []byte

func (*EncryptedPayload) ProtoMessage 

func (*EncryptedPayload) ProtoMessage()

func (*EncryptedPayload) Reset 

func (m *EncryptedPayload) Reset()

func (*EncryptedPayload) String 

func (m *EncryptedPayload) String() string

func (*EncryptedPayload) XXX_DiscardUnknown 

func (m *EncryptedPayload) XXX_DiscardUnknown()

func (*EncryptedPayload) XXX_Marshal 

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

func (*EncryptedPayload) XXX_Merge 

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

func (*EncryptedPayload) XXX_Size 

func (m *EncryptedPayload) XXX_Size() int

func (*EncryptedPayload) XXX_Unmarshal 

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

type PartyInfo 

type PartyInfo struct {
	// the URL identifying this node
	Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	// public key of the respective URL
	Recipients map[string][]byte `` /* 161-byte string literal not displayed */
	// All the URLs opf the connected nodes
	Parties              map[string]bool `` /* 156-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Node information

func (*PartyInfo) Descriptor 

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

func (*PartyInfo) GetParties 

func (m *PartyInfo) GetParties() map[string]bool

func (*PartyInfo) GetRecipients 

func (m *PartyInfo) GetRecipients() map[string][]byte

func (*PartyInfo) GetUrl 

func (m *PartyInfo) GetUrl() string

func (*PartyInfo) ProtoMessage 

func (*PartyInfo) ProtoMessage()

func (*PartyInfo) Reset 

func (m *PartyInfo) Reset()

func (*PartyInfo) String 

func (m *PartyInfo) String() string

func (*PartyInfo) XXX_DiscardUnknown 

func (m *PartyInfo) XXX_DiscardUnknown()

func (*PartyInfo) XXX_Marshal 

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

func (*PartyInfo) XXX_Merge 

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

func (*PartyInfo) XXX_Size 

func (m *PartyInfo) XXX_Size() int

func (*PartyInfo) XXX_Unmarshal 

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

type PartyInfoResponse 

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

Payload consisting of the partyinfo of the connected party

func (*PartyInfoResponse) Descriptor 

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

func (*PartyInfoResponse) GetPayload 

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

func (*PartyInfoResponse) ProtoMessage 

func (*PartyInfoResponse) ProtoMessage()

func (*PartyInfoResponse) Reset 

func (m *PartyInfoResponse) Reset()

func (*PartyInfoResponse) String 

func (m *PartyInfoResponse) String() string

func (*PartyInfoResponse) XXX_DiscardUnknown 

func (m *PartyInfoResponse) XXX_DiscardUnknown()

func (*PartyInfoResponse) XXX_Marshal 

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

func (*PartyInfoResponse) XXX_Merge 

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

func (*PartyInfoResponse) XXX_Size 

func (m *PartyInfoResponse) XXX_Size() int

func (*PartyInfoResponse) XXX_Unmarshal 

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

type PushPayload 

type PushPayload struct {
	Ep *EncryptedPayload `protobuf:"bytes,1,opt,name=ep,proto3" json:"ep,omitempty"`
	// Encoded transaction information
	Encoded              []byte   `protobuf:"bytes,2,opt,name=encoded,proto3" json:"encoded,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

The message type to sent over to other Chimera nodes.

func (*PushPayload) Descriptor 

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

func (*PushPayload) GetEncoded 

func (m *PushPayload) GetEncoded() []byte

func (*PushPayload) GetEp 

func (m *PushPayload) GetEp() *EncryptedPayload

func (*PushPayload) ProtoMessage 

func (*PushPayload) ProtoMessage()

func (*PushPayload) Reset 

func (m *PushPayload) Reset()

func (*PushPayload) String 

func (m *PushPayload) String() string

func (*PushPayload) XXX_DiscardUnknown 

func (m *PushPayload) XXX_DiscardUnknown()

func (*PushPayload) XXX_Marshal 

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

func (*PushPayload) XXX_Merge 

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

func (*PushPayload) XXX_Size 

func (m *PushPayload) XXX_Size() int

func (*PushPayload) XXX_Unmarshal 

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

type ReceiveRequest 

type ReceiveRequest struct {
	// The transaction hash to be queried
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The Senders key
	To                   string   `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Retrieve a transaction payload

func (*ReceiveRequest) Descriptor 

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

func (*ReceiveRequest) GetKey 

func (m *ReceiveRequest) GetKey() []byte

func (*ReceiveRequest) GetTo 

func (m *ReceiveRequest) GetTo() string

func (*ReceiveRequest) ProtoMessage 

func (*ReceiveRequest) ProtoMessage()

func (*ReceiveRequest) Reset 

func (m *ReceiveRequest) Reset()

func (*ReceiveRequest) String 

func (m *ReceiveRequest) String() string

func (*ReceiveRequest) XXX_DiscardUnknown 

func (m *ReceiveRequest) XXX_DiscardUnknown()

func (*ReceiveRequest) XXX_Marshal 

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

func (*ReceiveRequest) XXX_Merge 

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

func (*ReceiveRequest) XXX_Size 

func (m *ReceiveRequest) XXX_Size() int

func (*ReceiveRequest) XXX_Unmarshal 

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

type ReceiveResponse 

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

Response for ReceiveRequest -> contains the transaction payload

func (*ReceiveResponse) Descriptor 

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

func (*ReceiveResponse) GetPayload 

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

func (*ReceiveResponse) ProtoMessage 

func (*ReceiveResponse) ProtoMessage()

func (*ReceiveResponse) Reset 

func (m *ReceiveResponse) Reset()

func (*ReceiveResponse) String 

func (m *ReceiveResponse) String() string

func (*ReceiveResponse) XXX_DiscardUnknown 

func (m *ReceiveResponse) XXX_DiscardUnknown()

func (*ReceiveResponse) XXX_Marshal 

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

func (*ReceiveResponse) XXX_Merge 

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

func (*ReceiveResponse) XXX_Size 

func (m *ReceiveResponse) XXX_Size() int

func (*ReceiveResponse) XXX_Unmarshal 

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

type ResendRequest 

type ResendRequest struct {
	// Type is the resend request type. It should be either "all" or "individual" depending on if
	// you want to request an individual transaction, or all transactions associated with a node.
	Type                 string   `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"`
	PublicKey            []byte   `protobuf:"bytes,2,opt,name=PublicKey,proto3" json:"PublicKey,omitempty"`
	Key                  []byte   `protobuf:"bytes,3,opt,name=Key,proto3" json:"Key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ResendRequest is used to resend previous transactions. There are two types of supported request. 1. All transactions associated with a node, in which case the Key field should be omitted. 2. A specific transaction with the given key value.

func (*ResendRequest) Descriptor 

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

func (*ResendRequest) GetKey 

func (m *ResendRequest) GetKey() []byte

func (*ResendRequest) GetPublicKey 

func (m *ResendRequest) GetPublicKey() []byte

func (*ResendRequest) GetType 

func (m *ResendRequest) GetType() string

func (*ResendRequest) ProtoMessage 

func (*ResendRequest) ProtoMessage()

func (*ResendRequest) Reset 

func (m *ResendRequest) Reset()

func (*ResendRequest) String 

func (m *ResendRequest) String() string

func (*ResendRequest) XXX_DiscardUnknown 

func (m *ResendRequest) XXX_DiscardUnknown()

func (*ResendRequest) XXX_Marshal 

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

func (*ResendRequest) XXX_Merge 

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

func (*ResendRequest) XXX_Size 

func (m *ResendRequest) XXX_Size() int

func (*ResendRequest) XXX_Unmarshal 

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

type ResendResponse 

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

func (*ResendResponse) Descriptor 

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

func (*ResendResponse) GetEncoded 

func (m *ResendResponse) GetEncoded() []byte

func (*ResendResponse) ProtoMessage 

func (*ResendResponse) ProtoMessage()

func (*ResendResponse) Reset 

func (m *ResendResponse) Reset()

func (*ResendResponse) String 

func (m *ResendResponse) String() string

func (*ResendResponse) XXX_DiscardUnknown 

func (m *ResendResponse) XXX_DiscardUnknown()

func (*ResendResponse) XXX_Marshal 

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

func (*ResendResponse) XXX_Merge 

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

func (*ResendResponse) XXX_Size 

func (m *ResendResponse) XXX_Size() int

func (*ResendResponse) XXX_Unmarshal 

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

type SendRequest 

type SendRequest struct {
	// The payload of the transaction to be sent
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// The key of the Sender
	From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	// The keys of all the Receipients who are privy to the transaction
	To                   []string `protobuf:"bytes,3,rep,name=to,proto3" json:"to,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Store a transaction payload

func (*SendRequest) Descriptor 

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

func (*SendRequest) GetFrom 

func (m *SendRequest) GetFrom() string

func (*SendRequest) GetPayload 

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

func (*SendRequest) GetTo 

func (m *SendRequest) GetTo() []string

func (*SendRequest) ProtoMessage 

func (*SendRequest) ProtoMessage()

func (*SendRequest) Reset 

func (m *SendRequest) Reset()

func (*SendRequest) String 

func (m *SendRequest) String() string

func (*SendRequest) XXX_DiscardUnknown 

func (m *SendRequest) XXX_DiscardUnknown()

func (*SendRequest) XXX_Marshal 

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

func (*SendRequest) XXX_Merge 

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

func (*SendRequest) XXX_Size 

func (m *SendRequest) XXX_Size() int

func (*SendRequest) XXX_Unmarshal 

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

type SendResponse 

type SendResponse struct {
	// The transaction hash is returned
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response from the server for the SendRequest

func (*SendResponse) Descriptor 

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

func (*SendResponse) GetKey 

func (m *SendResponse) GetKey() []byte

func (*SendResponse) ProtoMessage 

func (*SendResponse) ProtoMessage()

func (*SendResponse) Reset 

func (m *SendResponse) Reset()

func (*SendResponse) String 

func (m *SendResponse) String() string

func (*SendResponse) XXX_DiscardUnknown 

func (m *SendResponse) XXX_DiscardUnknown()

func (*SendResponse) XXX_Marshal 

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

func (*SendResponse) XXX_Merge 

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

func (*SendResponse) XXX_Size 

func (m *SendResponse) XXX_Size() int

func (*SendResponse) XXX_Unmarshal 

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

type SendSignedRequest 

type SendSignedRequest struct {
	// The payload of the transaction to be sent
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// The keys of all the Receipients who are privy to the transaction
	To                   []string `protobuf:"bytes,2,rep,name=to,proto3" json:"to,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Store a signed transaction payload

func (*SendSignedRequest) Descriptor 

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

func (*SendSignedRequest) GetPayload 

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

func (*SendSignedRequest) GetTo 

func (m *SendSignedRequest) GetTo() []string

func (*SendSignedRequest) ProtoMessage 

func (*SendSignedRequest) ProtoMessage()

func (*SendSignedRequest) Reset 

func (m *SendSignedRequest) Reset()

func (*SendSignedRequest) String 

func (m *SendSignedRequest) String() string

func (*SendSignedRequest) XXX_DiscardUnknown 

func (m *SendSignedRequest) XXX_DiscardUnknown()

func (*SendSignedRequest) XXX_Marshal 

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

func (*SendSignedRequest) XXX_Merge 

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

func (*SendSignedRequest) XXX_Size 

func (m *SendSignedRequest) XXX_Size() int

func (*SendSignedRequest) XXX_Unmarshal 

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

type StoreRequest 

type StoreRequest struct {
	// The payload of the transaction to be sent
	Payload              []byte   `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Store a transaction payload locally and return a encrypted hash

func (*StoreRequest) Descriptor 

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

func (*StoreRequest) GetPayload 

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

func (*StoreRequest) ProtoMessage 

func (*StoreRequest) ProtoMessage()

func (*StoreRequest) Reset 

func (m *StoreRequest) Reset()

func (*StoreRequest) String 

func (m *StoreRequest) String() string

func (*StoreRequest) XXX_DiscardUnknown 

func (m *StoreRequest) XXX_DiscardUnknown()

func (*StoreRequest) XXX_Marshal 

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

func (*StoreRequest) XXX_Merge 

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

func (*StoreRequest) XXX_Size 

func (m *StoreRequest) XXX_Size() int

func (*StoreRequest) XXX_Unmarshal 

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

type UnimplementedClientServer 

type UnimplementedClientServer struct {
}

UnimplementedClientServer can be embedded to have forward compatible implementations.

func (*UnimplementedClientServer) Delete 

func (*UnimplementedClientServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteRequest, error)

func (*UnimplementedClientServer) GetPartyInfo 

func (*UnimplementedClientServer) GetPartyInfo(ctx context.Context, req *PartyInfo) (*PartyInfo, error)

func (*UnimplementedClientServer) Push 

func (*UnimplementedClientServer) Push(ctx context.Context, req *PushPayload) (*PartyInfoResponse, error)

func (*UnimplementedClientServer) Receive 

func (*UnimplementedClientServer) Receive(ctx context.Context, req *ReceiveRequest) (*ReceiveResponse, error)

func (*UnimplementedClientServer) Resend 

func (*UnimplementedClientServer) Resend(ctx context.Context, req *ResendRequest) (*ResendResponse, error)

func (*UnimplementedClientServer) Send 

func (*UnimplementedClientServer) Send(ctx context.Context, req *SendRequest) (*SendResponse, error)

func (*UnimplementedClientServer) SendSignedTx 

func (*UnimplementedClientServer) SendSignedTx(ctx context.Context, req *SendSignedRequest) (*SendResponse, error)

func (*UnimplementedClientServer) StoreRaw 

func (*UnimplementedClientServer) StoreRaw(ctx context.Context, req *StoreRequest) (*SendResponse, error)

func (*UnimplementedClientServer) Upcheck 

func (*UnimplementedClientServer) Upcheck(ctx context.Context, req *UpCheckResponse) (*UpCheckResponse, error)

func (*UnimplementedClientServer) UpdatePartyInfo 

func (*UnimplementedClientServer) UpdatePartyInfo(ctx context.Context, req *PartyInfo) (*PartyInfoResponse, error)

func (*UnimplementedClientServer) Version 

func (*UnimplementedClientServer) Version(ctx context.Context, req *ApiVersion) (*ApiVersion, error)

type UpCheckResponse 

type UpCheckResponse 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:"-"`
}

The server response from an `upcheck` request

func (*UpCheckResponse) Descriptor 

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

func (*UpCheckResponse) GetMessage 

func (m *UpCheckResponse) GetMessage() string

func (*UpCheckResponse) ProtoMessage 

func (*UpCheckResponse) ProtoMessage()

func (*UpCheckResponse) Reset 

func (m *UpCheckResponse) Reset()

func (*UpCheckResponse) String 

func (m *UpCheckResponse) String() string

func (*UpCheckResponse) XXX_DiscardUnknown 

func (m *UpCheckResponse) XXX_DiscardUnknown()

func (*UpCheckResponse) XXX_Marshal 

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

func (*UpCheckResponse) XXX_Merge 

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

func (*UpCheckResponse) XXX_Size 

func (m *UpCheckResponse) XXX_Size() int

func (*UpCheckResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.