ccmsg

package
v0.0.0-...-9742f5a Latest Latest
Warning

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

 Go to latest Published: Oct 29, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBootstrap = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBootstrap   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthCachePublisher = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCachePublisher   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthClientCache = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowClientCache   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthClientPublisher = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowClientPublisher   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthCommon = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCommon   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthFaucet = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFaucet   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthLedger = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLedger   = fmt.Errorf("proto: integer overflow")
)
View Source 
var (
	ErrInvalidLengthPublisherCache = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPublisherCache   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ContentRequest_ClientCacheStatus_Status_name = map[int32]string{
	0: "DEFAULT",
	1: "UNUSABLE",
}
View Source 
var ContentRequest_ClientCacheStatus_Status_value = map[string]int32{
	"DEFAULT":  0,
	"UNUSABLE": 1,
}

Functions

func RegisterCachePublisherServer 

func RegisterCachePublisherServer(s *grpc.Server, srv CachePublisherServer)

func RegisterClientCacheServer 

func RegisterClientCacheServer(s *grpc.Server, srv ClientCacheServer)

func RegisterClientPublisherServer 

func RegisterClientPublisherServer(s *grpc.Server, srv ClientPublisherServer)

func RegisterFaucetServer 

func RegisterFaucetServer(s *grpc.Server, srv FaucetServer)

func RegisterLedgerServer 

func RegisterLedgerServer(s *grpc.Server, srv LedgerServer)

func RegisterNodeBootstrapdServer 

func RegisterNodeBootstrapdServer(s *grpc.Server, srv NodeBootstrapdServer)

func RegisterPublisherCacheServer 

func RegisterPublisherCacheServer(s *grpc.Server, srv PublisherCacheServer)

Types

type BatchSignature 

type BatchSignature struct {
	PathDirection        []bool     `protobuf:"varint,2,rep,packed,name=path_direction,json=pathDirection,proto3" json:"path_direction,omitempty"`
	PathDigest           [][]byte   `protobuf:"bytes,3,rep,name=path_digest,json=pathDigest,proto3" json:"path_digest,omitempty"`
	RootSignature        []byte     `protobuf:"bytes,4,opt,name=root_signature,json=rootSignature,proto3" json:"root_signature,omitempty"`
	SigningKey           *PublicKey `protobuf:"bytes,5,opt,name=signing_key,json=signingKey,proto3" json:"signing_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*BatchSignature) Descriptor 

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

func (*BatchSignature) GetPathDigest 

func (m *BatchSignature) GetPathDigest() [][]byte

func (*BatchSignature) GetPathDirection 

func (m *BatchSignature) GetPathDirection() []bool

func (*BatchSignature) GetRootSignature 

func (m *BatchSignature) GetRootSignature() []byte

func (*BatchSignature) GetSigningKey 

func (m *BatchSignature) GetSigningKey() *PublicKey

func (*BatchSignature) Marshal 

func (m *BatchSignature) Marshal() (dAtA []byte, err error)

func (*BatchSignature) MarshalTo 

func (m *BatchSignature) MarshalTo(dAtA []byte) (int, error)

func (*BatchSignature) ProtoMessage 

func (*BatchSignature) ProtoMessage()

func (*BatchSignature) Reset 

func (m *BatchSignature) Reset()

func (*BatchSignature) Size 

func (m *BatchSignature) Size() (n int)

func (*BatchSignature) String 

func (m *BatchSignature) String() string

func (*BatchSignature) Unmarshal 

func (m *BatchSignature) Unmarshal(dAtA []byte) error

func (*BatchSignature) XXX_DiscardUnknown 

func (m *BatchSignature) XXX_DiscardUnknown()

func (*BatchSignature) XXX_Marshal 

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

func (*BatchSignature) XXX_Merge 

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

func (*BatchSignature) XXX_Size 

func (m *BatchSignature) XXX_Size() int

func (*BatchSignature) XXX_Unmarshal 

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

type BlockKey 

type BlockKey struct {
	// TODO: Add an enum for key type.
	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 (*BlockKey) Descriptor 

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

func (*BlockKey) GetKey 

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

func (*BlockKey) Marshal 

func (m *BlockKey) Marshal() (dAtA []byte, err error)

func (*BlockKey) MarshalTo 

func (m *BlockKey) MarshalTo(dAtA []byte) (int, error)

func (*BlockKey) ProtoMessage 

func (*BlockKey) ProtoMessage()

func (*BlockKey) Reset 

func (m *BlockKey) Reset()

func (*BlockKey) Size 

func (m *BlockKey) Size() (n int)

func (*BlockKey) String 

func (m *BlockKey) String() string

func (*BlockKey) Unmarshal 

func (m *BlockKey) Unmarshal(dAtA []byte) error

func (*BlockKey) XXX_DiscardUnknown 

func (m *BlockKey) XXX_DiscardUnknown()

func (*BlockKey) XXX_Marshal 

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

func (*BlockKey) XXX_Merge 

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

func (*BlockKey) XXX_Size 

func (m *BlockKey) XXX_Size() int

func (*BlockKey) XXX_Unmarshal 

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

type CacheAnnounceRequest 

type CacheAnnounceRequest struct {
	// TODO: there's no proof the public_key belongs to us
	PublicKey            []byte   `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	Version              string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	FreeMemory           uint64   `protobuf:"varint,3,opt,name=free_memory,json=freeMemory,proto3" json:"free_memory,omitempty"`
	TotalMemory          uint64   `protobuf:"varint,4,opt,name=total_memory,json=totalMemory,proto3" json:"total_memory,omitempty"`
	FreeDisk             uint64   `protobuf:"varint,5,opt,name=free_disk,json=freeDisk,proto3" json:"free_disk,omitempty"`
	TotalDisk            uint64   `protobuf:"varint,6,opt,name=total_disk,json=totalDisk,proto3" json:"total_disk,omitempty"`
	StartupTime          int64    `protobuf:"varint,7,opt,name=startup_time,json=startupTime,proto3" json:"startup_time,omitempty"`
	ContactUrl           string   `protobuf:"bytes,8,opt,name=contact_url,json=contactUrl,proto3" json:"contact_url,omitempty"`
	Port                 uint32   `protobuf:"varint,9,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CacheAnnounceRequest) Descriptor 

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

func (*CacheAnnounceRequest) GetContactUrl 

func (m *CacheAnnounceRequest) GetContactUrl() string

func (*CacheAnnounceRequest) GetFreeDisk 

func (m *CacheAnnounceRequest) GetFreeDisk() uint64

func (*CacheAnnounceRequest) GetFreeMemory 

func (m *CacheAnnounceRequest) GetFreeMemory() uint64

func (*CacheAnnounceRequest) GetPort 

func (m *CacheAnnounceRequest) GetPort() uint32

func (*CacheAnnounceRequest) GetPublicKey 

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

func (*CacheAnnounceRequest) GetStartupTime 

func (m *CacheAnnounceRequest) GetStartupTime() int64

func (*CacheAnnounceRequest) GetTotalDisk 

func (m *CacheAnnounceRequest) GetTotalDisk() uint64

func (*CacheAnnounceRequest) GetTotalMemory 

func (m *CacheAnnounceRequest) GetTotalMemory() uint64

func (*CacheAnnounceRequest) GetVersion 

func (m *CacheAnnounceRequest) GetVersion() string

func (*CacheAnnounceRequest) Marshal 

func (m *CacheAnnounceRequest) Marshal() (dAtA []byte, err error)

func (*CacheAnnounceRequest) MarshalTo 

func (m *CacheAnnounceRequest) MarshalTo(dAtA []byte) (int, error)

func (*CacheAnnounceRequest) ProtoMessage 

func (*CacheAnnounceRequest) ProtoMessage()

func (*CacheAnnounceRequest) Reset 

func (m *CacheAnnounceRequest) Reset()

func (*CacheAnnounceRequest) Size 

func (m *CacheAnnounceRequest) Size() (n int)

func (*CacheAnnounceRequest) String 

func (m *CacheAnnounceRequest) String() string

func (*CacheAnnounceRequest) Unmarshal 

func (m *CacheAnnounceRequest) Unmarshal(dAtA []byte) error

func (*CacheAnnounceRequest) XXX_DiscardUnknown 

func (m *CacheAnnounceRequest) XXX_DiscardUnknown()

func (*CacheAnnounceRequest) XXX_Marshal 

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

func (*CacheAnnounceRequest) XXX_Merge 

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

func (*CacheAnnounceRequest) XXX_Size 

func (m *CacheAnnounceRequest) XXX_Size() int

func (*CacheAnnounceRequest) XXX_Unmarshal 

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

type CacheAnnounceResponse 

type CacheAnnounceResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CacheAnnounceResponse) Descriptor 

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

func (*CacheAnnounceResponse) Marshal 

func (m *CacheAnnounceResponse) Marshal() (dAtA []byte, err error)

func (*CacheAnnounceResponse) MarshalTo 

func (m *CacheAnnounceResponse) MarshalTo(dAtA []byte) (int, error)

func (*CacheAnnounceResponse) ProtoMessage 

func (*CacheAnnounceResponse) ProtoMessage()

func (*CacheAnnounceResponse) Reset 

func (m *CacheAnnounceResponse) Reset()

func (*CacheAnnounceResponse) Size 

func (m *CacheAnnounceResponse) Size() (n int)

func (*CacheAnnounceResponse) String 

func (m *CacheAnnounceResponse) String() string

func (*CacheAnnounceResponse) Unmarshal 

func (m *CacheAnnounceResponse) Unmarshal(dAtA []byte) error

func (*CacheAnnounceResponse) XXX_DiscardUnknown 

func (m *CacheAnnounceResponse) XXX_DiscardUnknown()

func (*CacheAnnounceResponse) XXX_Marshal 

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

func (*CacheAnnounceResponse) XXX_Merge 

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

func (*CacheAnnounceResponse) XXX_Size 

func (m *CacheAnnounceResponse) XXX_Size() int

func (*CacheAnnounceResponse) XXX_Unmarshal 

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

type CacheDescription 

type CacheDescription struct {
	PublicKey            []byte   `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	Version              string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	FreeMemory           uint64   `protobuf:"varint,3,opt,name=free_memory,json=freeMemory,proto3" json:"free_memory,omitempty"`
	TotalMemory          uint64   `protobuf:"varint,4,opt,name=total_memory,json=totalMemory,proto3" json:"total_memory,omitempty"`
	FreeDisk             uint64   `protobuf:"varint,5,opt,name=free_disk,json=freeDisk,proto3" json:"free_disk,omitempty"`
	TotalDisk            uint64   `protobuf:"varint,6,opt,name=total_disk,json=totalDisk,proto3" json:"total_disk,omitempty"`
	StartupTime          int64    `protobuf:"varint,7,opt,name=startup_time,json=startupTime,proto3" json:"startup_time,omitempty"`
	ContactUrl           string   `protobuf:"bytes,8,opt,name=contact_url,json=contactUrl,proto3" json:"contact_url,omitempty"`
	ExternalIp           string   `protobuf:"bytes,9,opt,name=external_ip,json=externalIp,proto3" json:"external_ip,omitempty"`
	Port                 uint32   `protobuf:"varint,10,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CacheDescription) Descriptor 

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

func (*CacheDescription) GetContactUrl 

func (m *CacheDescription) GetContactUrl() string

func (*CacheDescription) GetExternalIp 

func (m *CacheDescription) GetExternalIp() string

func (*CacheDescription) GetFreeDisk 

func (m *CacheDescription) GetFreeDisk() uint64

func (*CacheDescription) GetFreeMemory 

func (m *CacheDescription) GetFreeMemory() uint64

func (*CacheDescription) GetPort 

func (m *CacheDescription) GetPort() uint32

func (*CacheDescription) GetPublicKey 

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

func (*CacheDescription) GetStartupTime 

func (m *CacheDescription) GetStartupTime() int64

func (*CacheDescription) GetTotalDisk 

func (m *CacheDescription) GetTotalDisk() uint64

func (*CacheDescription) GetTotalMemory 

func (m *CacheDescription) GetTotalMemory() uint64

func (*CacheDescription) GetVersion 

func (m *CacheDescription) GetVersion() string

func (*CacheDescription) Marshal 

func (m *CacheDescription) Marshal() (dAtA []byte, err error)

func (*CacheDescription) MarshalTo 

func (m *CacheDescription) MarshalTo(dAtA []byte) (int, error)

func (*CacheDescription) ProtoMessage 

func (*CacheDescription) ProtoMessage()

func (*CacheDescription) Reset 

func (m *CacheDescription) Reset()

func (*CacheDescription) Size 

func (m *CacheDescription) Size() (n int)

func (*CacheDescription) String 

func (m *CacheDescription) String() string

func (*CacheDescription) Unmarshal 

func (m *CacheDescription) Unmarshal(dAtA []byte) error

func (*CacheDescription) XXX_DiscardUnknown 

func (m *CacheDescription) XXX_DiscardUnknown()

func (*CacheDescription) XXX_Marshal 

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

func (*CacheDescription) XXX_Merge 

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

func (*CacheDescription) XXX_Size 

func (m *CacheDescription) XXX_Size() int

func (*CacheDescription) XXX_Unmarshal 

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

type CacheFetchRequest 

type CacheFetchRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CacheFetchRequest) Descriptor 

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

func (*CacheFetchRequest) Marshal 

func (m *CacheFetchRequest) Marshal() (dAtA []byte, err error)

func (*CacheFetchRequest) MarshalTo 

func (m *CacheFetchRequest) MarshalTo(dAtA []byte) (int, error)

func (*CacheFetchRequest) ProtoMessage 

func (*CacheFetchRequest) ProtoMessage()

func (*CacheFetchRequest) Reset 

func (m *CacheFetchRequest) Reset()

func (*CacheFetchRequest) Size 

func (m *CacheFetchRequest) Size() (n int)

func (*CacheFetchRequest) String 

func (m *CacheFetchRequest) String() string

func (*CacheFetchRequest) Unmarshal 

func (m *CacheFetchRequest) Unmarshal(dAtA []byte) error

func (*CacheFetchRequest) XXX_DiscardUnknown 

func (m *CacheFetchRequest) XXX_DiscardUnknown()

func (*CacheFetchRequest) XXX_Marshal 

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

func (*CacheFetchRequest) XXX_Merge 

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

func (*CacheFetchRequest) XXX_Size 

func (m *CacheFetchRequest) XXX_Size() int

func (*CacheFetchRequest) XXX_Unmarshal 

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

type CacheFetchResponse 

type CacheFetchResponse struct {
	Caches               []*CacheDescription `protobuf:"bytes,1,rep,name=caches,proto3" json:"caches,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*CacheFetchResponse) Descriptor 

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

func (*CacheFetchResponse) GetCaches 

func (m *CacheFetchResponse) GetCaches() []*CacheDescription

func (*CacheFetchResponse) Marshal 

func (m *CacheFetchResponse) Marshal() (dAtA []byte, err error)

func (*CacheFetchResponse) MarshalTo 

func (m *CacheFetchResponse) MarshalTo(dAtA []byte) (int, error)

func (*CacheFetchResponse) ProtoMessage 

func (*CacheFetchResponse) ProtoMessage()

func (*CacheFetchResponse) Reset 

func (m *CacheFetchResponse) Reset()

func (*CacheFetchResponse) Size 

func (m *CacheFetchResponse) Size() (n int)

func (*CacheFetchResponse) String 

func (m *CacheFetchResponse) String() string

func (*CacheFetchResponse) Unmarshal 

func (m *CacheFetchResponse) Unmarshal(dAtA []byte) error

func (*CacheFetchResponse) XXX_DiscardUnknown 

func (m *CacheFetchResponse) XXX_DiscardUnknown()

func (*CacheFetchResponse) XXX_Marshal 

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

func (*CacheFetchResponse) XXX_Merge 

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

func (*CacheFetchResponse) XXX_Size 

func (m *CacheFetchResponse) XXX_Size() int

func (*CacheFetchResponse) XXX_Unmarshal 

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

type CacheInfo 

type CacheInfo struct {
	Addr                 *NetworkAddress `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Pubkey               *PublicKey      `protobuf:"bytes,2,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*CacheInfo) Descriptor 

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

func (*CacheInfo) GetAddr 

func (m *CacheInfo) GetAddr() *NetworkAddress

func (*CacheInfo) GetPubkey 

func (m *CacheInfo) GetPubkey() *PublicKey

func (*CacheInfo) Marshal 

func (m *CacheInfo) Marshal() (dAtA []byte, err error)

func (*CacheInfo) MarshalTo 

func (m *CacheInfo) MarshalTo(dAtA []byte) (int, error)

func (*CacheInfo) ProtoMessage 

func (*CacheInfo) ProtoMessage()

func (*CacheInfo) Reset 

func (m *CacheInfo) Reset()

func (*CacheInfo) Size 

func (m *CacheInfo) Size() (n int)

func (*CacheInfo) String 

func (m *CacheInfo) String() string

func (*CacheInfo) Unmarshal 

func (m *CacheInfo) Unmarshal(dAtA []byte) error

func (*CacheInfo) XXX_DiscardUnknown 

func (m *CacheInfo) XXX_DiscardUnknown()

func (*CacheInfo) XXX_Marshal 

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

func (*CacheInfo) XXX_Merge 

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

func (*CacheInfo) XXX_Size 

func (m *CacheInfo) XXX_Size() int

func (*CacheInfo) XXX_Unmarshal 

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

type CacheMissRequest 

type CacheMissRequest struct {
	// In chunks.
	// XXX: This was formerly in bytes.  Was there a good reason for that?
	RangeBegin           uint64   `protobuf:"varint,2,opt,name=range_begin,json=rangeBegin,proto3" json:"range_begin,omitempty"`
	RangeEnd             uint64   `protobuf:"varint,3,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
	ObjectId             []byte   `protobuf:"bytes,4,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

XXX: See similarities to ContentRequest.

func (*CacheMissRequest) Descriptor 

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

func (*CacheMissRequest) GetObjectId 

func (m *CacheMissRequest) GetObjectId() []byte

func (*CacheMissRequest) GetRangeBegin 

func (m *CacheMissRequest) GetRangeBegin() uint64

func (*CacheMissRequest) GetRangeEnd 

func (m *CacheMissRequest) GetRangeEnd() uint64

func (*CacheMissRequest) Marshal 

func (m *CacheMissRequest) Marshal() (dAtA []byte, err error)

func (*CacheMissRequest) MarshalTo 

func (m *CacheMissRequest) MarshalTo(dAtA []byte) (int, error)

func (*CacheMissRequest) ProtoMessage 

func (*CacheMissRequest) ProtoMessage()

func (*CacheMissRequest) Reset 

func (m *CacheMissRequest) Reset()

func (*CacheMissRequest) Size 

func (m *CacheMissRequest) Size() (n int)

func (*CacheMissRequest) String 

func (m *CacheMissRequest) String() string

func (*CacheMissRequest) Unmarshal 

func (m *CacheMissRequest) Unmarshal(dAtA []byte) error

func (*CacheMissRequest) XXX_DiscardUnknown 

func (m *CacheMissRequest) XXX_DiscardUnknown()

func (*CacheMissRequest) XXX_Marshal 

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

func (*CacheMissRequest) XXX_Merge 

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

func (*CacheMissRequest) XXX_Size 

func (m *CacheMissRequest) XXX_Size() int

func (*CacheMissRequest) XXX_Unmarshal 

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

type CacheMissResponse 

type CacheMissResponse struct {
	Metadata             *ObjectMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Chunks               []*Chunk        `protobuf:"bytes,2,rep,name=chunks,proto3" json:"chunks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*CacheMissResponse) Descriptor 

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

func (*CacheMissResponse) GetChunks 

func (m *CacheMissResponse) GetChunks() []*Chunk

func (*CacheMissResponse) GetMetadata 

func (m *CacheMissResponse) GetMetadata() *ObjectMetadata

func (*CacheMissResponse) Marshal 

func (m *CacheMissResponse) Marshal() (dAtA []byte, err error)

func (*CacheMissResponse) MarshalTo 

func (m *CacheMissResponse) MarshalTo(dAtA []byte) (int, error)

func (*CacheMissResponse) ProtoMessage 

func (*CacheMissResponse) ProtoMessage()

func (*CacheMissResponse) Reset 

func (m *CacheMissResponse) Reset()

func (*CacheMissResponse) Size 

func (m *CacheMissResponse) Size() (n int)

func (*CacheMissResponse) String 

func (m *CacheMissResponse) String() string

func (*CacheMissResponse) Unmarshal 

func (m *CacheMissResponse) Unmarshal(dAtA []byte) error

func (*CacheMissResponse) XXX_DiscardUnknown 

func (m *CacheMissResponse) XXX_DiscardUnknown()

func (*CacheMissResponse) XXX_Marshal 

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

func (*CacheMissResponse) XXX_Merge 

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

func (*CacheMissResponse) XXX_Size 

func (m *CacheMissResponse) XXX_Size() int

func (*CacheMissResponse) XXX_Unmarshal 

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

type CachePublisherClient 

type CachePublisherClient interface {
	CacheMiss(ctx context.Context, in *CacheMissRequest, opts ...grpc.CallOption) (*CacheMissResponse, error)
}

CachePublisherClient is the client API for CachePublisher service.

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

func NewCachePublisherClient 

func NewCachePublisherClient(cc *grpc.ClientConn) CachePublisherClient

type CachePublisherServer 

type CachePublisherServer interface {
	CacheMiss(context.Context, *CacheMissRequest) (*CacheMissResponse, error)
}

CachePublisherServer is the server API for CachePublisher service.

type Certificate 

type Certificate struct {
	SubjectPublicKey     *PublicKey `protobuf:"bytes,1,opt,name=subject_public_key,json=subjectPublicKey,proto3" json:"subject_public_key,omitempty"`
	EscrowId             []byte     `protobuf:"bytes,2,opt,name=escrow_id,json=escrowId,proto3" json:"escrow_id,omitempty"`
	Usage                string     `protobuf:"bytes,3,opt,name=usage,proto3" json:"usage,omitempty"`
	Signature            []byte     `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Signed by escrow key; ensures that the key that produced the batch signature is authorized.

func (*Certificate) Descriptor 

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

func (*Certificate) GetEscrowId 

func (m *Certificate) GetEscrowId() []byte

func (*Certificate) GetSignature 

func (m *Certificate) GetSignature() []byte

func (*Certificate) GetSubjectPublicKey 

func (m *Certificate) GetSubjectPublicKey() *PublicKey

func (*Certificate) GetUsage 

func (m *Certificate) GetUsage() string

func (*Certificate) Marshal 

func (m *Certificate) Marshal() (dAtA []byte, err error)

func (*Certificate) MarshalTo 

func (m *Certificate) MarshalTo(dAtA []byte) (int, error)

func (*Certificate) ProtoMessage 

func (*Certificate) ProtoMessage()

func (*Certificate) Reset 

func (m *Certificate) Reset()

func (*Certificate) Size 

func (m *Certificate) Size() (n int)

func (*Certificate) String 

func (m *Certificate) String() string

func (*Certificate) Unmarshal 

func (m *Certificate) Unmarshal(dAtA []byte) error

func (*Certificate) XXX_DiscardUnknown 

func (m *Certificate) XXX_DiscardUnknown()

func (*Certificate) XXX_Marshal 

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

func (*Certificate) XXX_Merge 

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

func (*Certificate) XXX_Size 

func (m *Certificate) XXX_Size() int

func (*Certificate) XXX_Unmarshal 

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

type Chunk 

type Chunk struct {
	SlotIdx uint64 `protobuf:"varint,1,opt,name=slot_idx,json=slotIdx,proto3" json:"slot_idx,omitempty"`
	// Types that are valid to be assigned to Source:
	//	*Chunk_Http
	//	*Chunk_Inline
	Source               isChunk_Source `protobuf_oneof:"source"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Chunk) Descriptor 

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

func (*Chunk) GetHttp 

func (m *Chunk) GetHttp() *ChunkSourceHTTP

func (*Chunk) GetInline 

func (m *Chunk) GetInline() *ChunkSourceInline

func (*Chunk) GetSlotIdx 

func (m *Chunk) GetSlotIdx() uint64

func (*Chunk) GetSource 

func (m *Chunk) GetSource() isChunk_Source

func (*Chunk) Marshal 

func (m *Chunk) Marshal() (dAtA []byte, err error)

func (*Chunk) MarshalTo 

func (m *Chunk) MarshalTo(dAtA []byte) (int, error)

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) Reset 

func (m *Chunk) Reset()

func (*Chunk) Size 

func (m *Chunk) Size() (n int)

func (*Chunk) String 

func (m *Chunk) String() string

func (*Chunk) Unmarshal 

func (m *Chunk) Unmarshal(dAtA []byte) error

func (*Chunk) XXX_DiscardUnknown 

func (m *Chunk) XXX_DiscardUnknown()

func (*Chunk) XXX_Marshal 

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

func (*Chunk) XXX_Merge 

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

func (*Chunk) XXX_OneofFuncs 

func (*Chunk) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Chunk) XXX_Size 

func (m *Chunk) XXX_Size() int

func (*Chunk) XXX_Unmarshal 

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

type ChunkSourceHTTP 

type ChunkSourceHTTP struct {
	Url                  string   `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	RangeBegin           uint64   `protobuf:"varint,2,opt,name=range_begin,json=rangeBegin,proto3" json:"range_begin,omitempty"`
	RangeEnd             uint64   `protobuf:"varint,3,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChunkSourceHTTP) Descriptor 

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

func (*ChunkSourceHTTP) GetRangeBegin 

func (m *ChunkSourceHTTP) GetRangeBegin() uint64

func (*ChunkSourceHTTP) GetRangeEnd 

func (m *ChunkSourceHTTP) GetRangeEnd() uint64

func (*ChunkSourceHTTP) GetUrl 

func (m *ChunkSourceHTTP) GetUrl() string

func (*ChunkSourceHTTP) Marshal 

func (m *ChunkSourceHTTP) Marshal() (dAtA []byte, err error)

func (*ChunkSourceHTTP) MarshalTo 

func (m *ChunkSourceHTTP) MarshalTo(dAtA []byte) (int, error)

func (*ChunkSourceHTTP) ProtoMessage 

func (*ChunkSourceHTTP) ProtoMessage()

func (*ChunkSourceHTTP) Reset 

func (m *ChunkSourceHTTP) Reset()

func (*ChunkSourceHTTP) Size 

func (m *ChunkSourceHTTP) Size() (n int)

func (*ChunkSourceHTTP) String 

func (m *ChunkSourceHTTP) String() string

func (*ChunkSourceHTTP) Unmarshal 

func (m *ChunkSourceHTTP) Unmarshal(dAtA []byte) error

func (*ChunkSourceHTTP) XXX_DiscardUnknown 

func (m *ChunkSourceHTTP) XXX_DiscardUnknown()

func (*ChunkSourceHTTP) XXX_Marshal 

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

func (*ChunkSourceHTTP) XXX_Merge 

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

func (*ChunkSourceHTTP) XXX_Size 

func (m *ChunkSourceHTTP) XXX_Size() int

func (*ChunkSourceHTTP) XXX_Unmarshal 

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

type ChunkSourceInline 

type ChunkSourceInline struct {
	Chunk                [][]byte `protobuf:"bytes,1,rep,name=chunk,proto3" json:"chunk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChunkSourceInline) Descriptor 

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

func (*ChunkSourceInline) GetChunk 

func (m *ChunkSourceInline) GetChunk() [][]byte

func (*ChunkSourceInline) Marshal 

func (m *ChunkSourceInline) Marshal() (dAtA []byte, err error)

func (*ChunkSourceInline) MarshalTo 

func (m *ChunkSourceInline) MarshalTo(dAtA []byte) (int, error)

func (*ChunkSourceInline) ProtoMessage 

func (*ChunkSourceInline) ProtoMessage()

func (*ChunkSourceInline) Reset 

func (m *ChunkSourceInline) Reset()

func (*ChunkSourceInline) Size 

func (m *ChunkSourceInline) Size() (n int)

func (*ChunkSourceInline) String 

func (m *ChunkSourceInline) String() string

func (*ChunkSourceInline) Unmarshal 

func (m *ChunkSourceInline) Unmarshal(dAtA []byte) error

func (*ChunkSourceInline) XXX_DiscardUnknown 

func (m *ChunkSourceInline) XXX_DiscardUnknown()

func (*ChunkSourceInline) XXX_Marshal 

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

func (*ChunkSourceInline) XXX_Merge 

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

func (*ChunkSourceInline) XXX_Size 

func (m *ChunkSourceInline) XXX_Size() int

func (*ChunkSourceInline) XXX_Unmarshal 

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

type Chunk_Http 

type Chunk_Http struct {
	Http *ChunkSourceHTTP `protobuf:"bytes,10,opt,name=http,proto3,oneof"`
}

func (*Chunk_Http) MarshalTo 

func (m *Chunk_Http) MarshalTo(dAtA []byte) (int, error)

func (*Chunk_Http) Size 

func (m *Chunk_Http) Size() (n int)

type Chunk_Inline 

type Chunk_Inline struct {
	Inline *ChunkSourceInline `protobuf:"bytes,20,opt,name=inline,proto3,oneof"`
}

func (*Chunk_Inline) MarshalTo 

func (m *Chunk_Inline) MarshalTo(dAtA []byte) (int, error)

func (*Chunk_Inline) Size 

func (m *Chunk_Inline) Size() (n int)

type ClientCacheClient 

type ClientCacheClient interface {
	GetChunk(ctx context.Context, in *ClientCacheRequest, opts ...grpc.CallOption) (*ClientCacheResponseData, error)
	ExchangeTicketL1(ctx context.Context, in *ClientCacheRequest, opts ...grpc.CallOption) (*ClientCacheResponseL1, error)
	ExchangeTicketL2(ctx context.Context, in *ClientCacheRequest, opts ...grpc.CallOption) (*ClientCacheResponseL2, error)
}

ClientCacheClient is the client API for ClientCache service.

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

func NewClientCacheClient 

func NewClientCacheClient(cc *grpc.ClientConn) ClientCacheClient

type ClientCacheRequest 

type ClientCacheRequest struct {
	SequenceNo      uint64                 `protobuf:"varint,8,opt,name=sequence_no,json=sequenceNo,proto3" json:"sequence_no,omitempty"`
	BundleRemainder *TicketBundleRemainder `protobuf:"bytes,1,opt,name=bundle_remainder,json=bundleRemainder,proto3" json:"bundle_remainder,omitempty"`
	// Types that are valid to be assigned to Ticket:
	//	*ClientCacheRequest_TicketRequest
	//	*ClientCacheRequest_TicketL1
	//	*ClientCacheRequest_TicketL2
	Ticket isClientCacheRequest_Ticket `protobuf_oneof:"ticket"`
	// Together, these fields allow the cache to verify that the request is authorized.
	TicketBundleSubdigests *TicketBundleSubdigests `` /* 129-byte string literal not displayed */
	BundleSig              *BatchSignature         `protobuf:"bytes,3,opt,name=bundle_sig,json=bundleSig,proto3" json:"bundle_sig,omitempty"`
	BundleSignerCert       *Certificate            `protobuf:"bytes,4,opt,name=bundle_signer_cert,json=bundleSignerCert,proto3" json:"bundle_signer_cert,omitempty"`
	XXX_NoUnkeyedLiteral   struct{}                `json:"-"`
	XXX_unrecognized       []byte                  `json:"-"`
	XXX_sizecache          int32                   `json:"-"`
}

func (*ClientCacheRequest) Descriptor 

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

func (*ClientCacheRequest) GetBundleRemainder 

func (m *ClientCacheRequest) GetBundleRemainder() *TicketBundleRemainder

func (*ClientCacheRequest) GetBundleSig 

func (m *ClientCacheRequest) GetBundleSig() *BatchSignature

func (*ClientCacheRequest) GetBundleSignerCert 

func (m *ClientCacheRequest) GetBundleSignerCert() *Certificate

func (*ClientCacheRequest) GetSequenceNo 

func (m *ClientCacheRequest) GetSequenceNo() uint64

func (*ClientCacheRequest) GetTicket 

func (m *ClientCacheRequest) GetTicket() isClientCacheRequest_Ticket

func (*ClientCacheRequest) GetTicketBundleSubdigests 

func (m *ClientCacheRequest) GetTicketBundleSubdigests() *TicketBundleSubdigests

func (*ClientCacheRequest) GetTicketL1 

func (m *ClientCacheRequest) GetTicketL1() *TicketL1

func (*ClientCacheRequest) GetTicketL2 

func (m *ClientCacheRequest) GetTicketL2() *TicketL2Info

func (*ClientCacheRequest) GetTicketRequest 

func (m *ClientCacheRequest) GetTicketRequest() *TicketRequest

func (*ClientCacheRequest) Marshal 

func (m *ClientCacheRequest) Marshal() (dAtA []byte, err error)

func (*ClientCacheRequest) MarshalTo 

func (m *ClientCacheRequest) MarshalTo(dAtA []byte) (int, error)

func (*ClientCacheRequest) ProtoMessage 

func (*ClientCacheRequest) ProtoMessage()

func (*ClientCacheRequest) Reset 

func (m *ClientCacheRequest) Reset()

func (*ClientCacheRequest) Size 

func (m *ClientCacheRequest) Size() (n int)

func (*ClientCacheRequest) String 

func (m *ClientCacheRequest) String() string

func (*ClientCacheRequest) Unmarshal 

func (m *ClientCacheRequest) Unmarshal(dAtA []byte) error

func (*ClientCacheRequest) XXX_DiscardUnknown 

func (m *ClientCacheRequest) XXX_DiscardUnknown()

func (*ClientCacheRequest) XXX_Marshal 

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

func (*ClientCacheRequest) XXX_Merge 

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

func (*ClientCacheRequest) XXX_OneofFuncs 

func (*ClientCacheRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ClientCacheRequest) XXX_Size 

func (m *ClientCacheRequest) XXX_Size() int

func (*ClientCacheRequest) XXX_Unmarshal 

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

type ClientCacheRequest_TicketL1 

type ClientCacheRequest_TicketL1 struct {
	TicketL1 *TicketL1 `protobuf:"bytes,6,opt,name=ticket_l1,json=ticketL1,proto3,oneof"`
}

func (*ClientCacheRequest_TicketL1) MarshalTo 

func (m *ClientCacheRequest_TicketL1) MarshalTo(dAtA []byte) (int, error)

func (*ClientCacheRequest_TicketL1) Size 

func (m *ClientCacheRequest_TicketL1) Size() (n int)

type ClientCacheRequest_TicketL2 

type ClientCacheRequest_TicketL2 struct {
	TicketL2 *TicketL2Info `protobuf:"bytes,7,opt,name=ticket_l2,json=ticketL2,proto3,oneof"`
}

func (*ClientCacheRequest_TicketL2) MarshalTo 

func (m *ClientCacheRequest_TicketL2) MarshalTo(dAtA []byte) (int, error)

func (*ClientCacheRequest_TicketL2) Size 

func (m *ClientCacheRequest_TicketL2) Size() (n int)

type ClientCacheRequest_TicketRequest 

type ClientCacheRequest_TicketRequest struct {
	TicketRequest *TicketRequest `protobuf:"bytes,5,opt,name=ticket_request,json=ticketRequest,proto3,oneof"`
}

func (*ClientCacheRequest_TicketRequest) MarshalTo 

func (m *ClientCacheRequest_TicketRequest) MarshalTo(dAtA []byte) (int, error)

func (*ClientCacheRequest_TicketRequest) Size 

func (m *ClientCacheRequest_TicketRequest) Size() (n int)

type ClientCacheResponse 

type ClientCacheResponse struct {
	// Identifies the request that this message is a response to.
	RequestSequenceNo uint64 `protobuf:"varint,1,opt,name=request_sequence_no,json=requestSequenceNo,proto3" json:"request_sequence_no,omitempty"`
	// Types that are valid to be assigned to Msg:
	//	*ClientCacheResponse_Error
	//	*ClientCacheResponse_DataResponse
	//	*ClientCacheResponse_L1Response
	//	*ClientCacheResponse_L2Response
	Msg                  isClientCacheResponse_Msg `protobuf_oneof:"msg"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

XXX: Remove me! This is not used over the wire; it's used only in the `cache` package.

func (*ClientCacheResponse) Descriptor 

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

func (*ClientCacheResponse) GetDataResponse 

func (m *ClientCacheResponse) GetDataResponse() *ClientCacheResponseData

func (*ClientCacheResponse) GetError 

func (m *ClientCacheResponse) GetError() *Error

func (*ClientCacheResponse) GetL1Response 

func (m *ClientCacheResponse) GetL1Response() *ClientCacheResponseL1

func (*ClientCacheResponse) GetL2Response 

func (m *ClientCacheResponse) GetL2Response() *ClientCacheResponseL2

func (*ClientCacheResponse) GetMsg 

func (m *ClientCacheResponse) GetMsg() isClientCacheResponse_Msg

func (*ClientCacheResponse) GetRequestSequenceNo 

func (m *ClientCacheResponse) GetRequestSequenceNo() uint64

func (*ClientCacheResponse) Marshal 

func (m *ClientCacheResponse) Marshal() (dAtA []byte, err error)

func (*ClientCacheResponse) MarshalTo 

func (m *ClientCacheResponse) MarshalTo(dAtA []byte) (int, error)

func (*ClientCacheResponse) ProtoMessage 

func (*ClientCacheResponse) ProtoMessage()

func (*ClientCacheResponse) Reset 

func (m *ClientCacheResponse) Reset()

func (*ClientCacheResponse) Size 

func (m *ClientCacheResponse) Size() (n int)

func (*ClientCacheResponse) String 

func (m *ClientCacheResponse) String() string

func (*ClientCacheResponse) Unmarshal 

func (m *ClientCacheResponse) Unmarshal(dAtA []byte) error

func (*ClientCacheResponse) XXX_DiscardUnknown 

func (m *ClientCacheResponse) XXX_DiscardUnknown()

func (*ClientCacheResponse) XXX_Marshal 

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

func (*ClientCacheResponse) XXX_Merge 

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

func (*ClientCacheResponse) XXX_OneofFuncs 

func (*ClientCacheResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*ClientCacheResponse) XXX_Size 

func (m *ClientCacheResponse) XXX_Size() int

func (*ClientCacheResponse) XXX_Unmarshal 

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

type ClientCacheResponseData 

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

func (*ClientCacheResponseData) Descriptor 

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

func (*ClientCacheResponseData) GetData 

func (m *ClientCacheResponseData) GetData() []byte

func (*ClientCacheResponseData) Marshal 

func (m *ClientCacheResponseData) Marshal() (dAtA []byte, err error)

func (*ClientCacheResponseData) MarshalTo 

func (m *ClientCacheResponseData) MarshalTo(dAtA []byte) (int, error)

func (*ClientCacheResponseData) ProtoMessage 

func (*ClientCacheResponseData) ProtoMessage()

func (*ClientCacheResponseData) Reset 

func (m *ClientCacheResponseData) Reset()

func (*ClientCacheResponseData) Size 

func (m *ClientCacheResponseData) Size() (n int)

func (*ClientCacheResponseData) String 

func (m *ClientCacheResponseData) String() string

func (*ClientCacheResponseData) Unmarshal 

func (m *ClientCacheResponseData) Unmarshal(dAtA []byte) error

func (*ClientCacheResponseData) XXX_DiscardUnknown 

func (m *ClientCacheResponseData) XXX_DiscardUnknown()

func (*ClientCacheResponseData) XXX_Marshal 

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

func (*ClientCacheResponseData) XXX_Merge 

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

func (*ClientCacheResponseData) XXX_Size 

func (m *ClientCacheResponseData) XXX_Size() int

func (*ClientCacheResponseData) XXX_Unmarshal 

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

type ClientCacheResponseL1 

type ClientCacheResponseL1 struct {
	// contains the outer key
	OuterKey             *BlockKey `protobuf:"bytes,1,opt,name=outer_key,json=outerKey,proto3" json:"outer_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ClientCacheResponseL1) Descriptor 

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

func (*ClientCacheResponseL1) GetOuterKey 

func (m *ClientCacheResponseL1) GetOuterKey() *BlockKey

func (*ClientCacheResponseL1) Marshal 

func (m *ClientCacheResponseL1) Marshal() (dAtA []byte, err error)

func (*ClientCacheResponseL1) MarshalTo 

func (m *ClientCacheResponseL1) MarshalTo(dAtA []byte) (int, error)

func (*ClientCacheResponseL1) ProtoMessage 

func (*ClientCacheResponseL1) ProtoMessage()

func (*ClientCacheResponseL1) Reset 

func (m *ClientCacheResponseL1) Reset()

func (*ClientCacheResponseL1) Size 

func (m *ClientCacheResponseL1) Size() (n int)

func (*ClientCacheResponseL1) String 

func (m *ClientCacheResponseL1) String() string

func (*ClientCacheResponseL1) Unmarshal 

func (m *ClientCacheResponseL1) Unmarshal(dAtA []byte) error

func (*ClientCacheResponseL1) XXX_DiscardUnknown 

func (m *ClientCacheResponseL1) XXX_DiscardUnknown()

func (*ClientCacheResponseL1) XXX_Marshal 

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

func (*ClientCacheResponseL1) XXX_Merge 

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

func (*ClientCacheResponseL1) XXX_Size 

func (m *ClientCacheResponseL1) XXX_Size() int

func (*ClientCacheResponseL1) XXX_Unmarshal 

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

type ClientCacheResponseL2 

type ClientCacheResponseL2 struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClientCacheResponseL2) Descriptor 

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

func (*ClientCacheResponseL2) Marshal 

func (m *ClientCacheResponseL2) Marshal() (dAtA []byte, err error)

func (*ClientCacheResponseL2) MarshalTo 

func (m *ClientCacheResponseL2) MarshalTo(dAtA []byte) (int, error)

func (*ClientCacheResponseL2) ProtoMessage 

func (*ClientCacheResponseL2) ProtoMessage()

func (*ClientCacheResponseL2) Reset 

func (m *ClientCacheResponseL2) Reset()

func (*ClientCacheResponseL2) Size 

func (m *ClientCacheResponseL2) Size() (n int)

func (*ClientCacheResponseL2) String 

func (m *ClientCacheResponseL2) String() string

func (*ClientCacheResponseL2) Unmarshal 

func (m *ClientCacheResponseL2) Unmarshal(dAtA []byte) error

func (*ClientCacheResponseL2) XXX_DiscardUnknown 

func (m *ClientCacheResponseL2) XXX_DiscardUnknown()

func (*ClientCacheResponseL2) XXX_Marshal 

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

func (*ClientCacheResponseL2) XXX_Merge 

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

func (*ClientCacheResponseL2) XXX_Size 

func (m *ClientCacheResponseL2) XXX_Size() int

func (*ClientCacheResponseL2) XXX_Unmarshal 

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

type ClientCacheResponse_DataResponse 

type ClientCacheResponse_DataResponse struct {
	DataResponse *ClientCacheResponseData `protobuf:"bytes,3,opt,name=data_response,json=dataResponse,proto3,oneof"`
}

func (*ClientCacheResponse_DataResponse) MarshalTo 

func (m *ClientCacheResponse_DataResponse) MarshalTo(dAtA []byte) (int, error)

func (*ClientCacheResponse_DataResponse) Size 

func (m *ClientCacheResponse_DataResponse) Size() (n int)

type ClientCacheResponse_Error 

type ClientCacheResponse_Error struct {
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

func (*ClientCacheResponse_Error) MarshalTo 

func (m *ClientCacheResponse_Error) MarshalTo(dAtA []byte) (int, error)

func (*ClientCacheResponse_Error) Size 

func (m *ClientCacheResponse_Error) Size() (n int)

type ClientCacheResponse_L1Response 

type ClientCacheResponse_L1Response struct {
	L1Response *ClientCacheResponseL1 `protobuf:"bytes,4,opt,name=l1_response,json=l1Response,proto3,oneof"`
}

func (*ClientCacheResponse_L1Response) MarshalTo 

func (m *ClientCacheResponse_L1Response) MarshalTo(dAtA []byte) (int, error)

func (*ClientCacheResponse_L1Response) Size 

func (m *ClientCacheResponse_L1Response) Size() (n int)

type ClientCacheResponse_L2Response 

type ClientCacheResponse_L2Response struct {
	L2Response *ClientCacheResponseL2 `protobuf:"bytes,5,opt,name=l2_response,json=l2Response,proto3,oneof"`
}

func (*ClientCacheResponse_L2Response) MarshalTo 

func (m *ClientCacheResponse_L2Response) MarshalTo(dAtA []byte) (int, error)

func (*ClientCacheResponse_L2Response) Size 

func (m *ClientCacheResponse_L2Response) Size() (n int)

type ClientCacheServer 

type ClientCacheServer interface {
	GetChunk(context.Context, *ClientCacheRequest) (*ClientCacheResponseData, error)
	ExchangeTicketL1(context.Context, *ClientCacheRequest) (*ClientCacheResponseL1, error)
	ExchangeTicketL2(context.Context, *ClientCacheRequest) (*ClientCacheResponseL2, error)
}

ClientCacheServer is the server API for ClientCache service.

type ClientPublisherClient 

type ClientPublisherClient interface {
	GetContent(ctx context.Context, in *ContentRequest, opts ...grpc.CallOption) (*ContentResponse, error)
}

ClientPublisherClient is the client API for ClientPublisher service.

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

func NewClientPublisherClient 

func NewClientPublisherClient(cc *grpc.ClientConn) ClientPublisherClient

type ClientPublisherServer 

type ClientPublisherServer interface {
	GetContent(context.Context, *ContentRequest) (*ContentResponse, error)
}

ClientPublisherServer is the server API for ClientPublisher service.

type ColocationPuzzleInfo 

type ColocationPuzzleInfo struct {
	Goal []byte `protobuf:"bytes,2,opt,name=goal,proto3" json:"goal,omitempty"`
	// THese fields come from the `colocationpuzzle.Parameters` struct.
	Rounds               uint32   `protobuf:"varint,1,opt,name=rounds,proto3" json:"rounds,omitempty"`
	StartOffset          uint64   `protobuf:"varint,3,opt,name=start_offset,json=startOffset,proto3" json:"start_offset,omitempty"`
	StartRange           uint64   `protobuf:"varint,4,opt,name=start_range,json=startRange,proto3" json:"start_range,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ColocationPuzzleInfo) Descriptor 

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

func (*ColocationPuzzleInfo) GetGoal 

func (m *ColocationPuzzleInfo) GetGoal() []byte

func (*ColocationPuzzleInfo) GetRounds 

func (m *ColocationPuzzleInfo) GetRounds() uint32

func (*ColocationPuzzleInfo) GetStartOffset 

func (m *ColocationPuzzleInfo) GetStartOffset() uint64

func (*ColocationPuzzleInfo) GetStartRange 

func (m *ColocationPuzzleInfo) GetStartRange() uint64

func (*ColocationPuzzleInfo) Marshal 

func (m *ColocationPuzzleInfo) Marshal() (dAtA []byte, err error)

func (*ColocationPuzzleInfo) MarshalTo 

func (m *ColocationPuzzleInfo) MarshalTo(dAtA []byte) (int, error)

func (*ColocationPuzzleInfo) ProtoMessage 

func (*ColocationPuzzleInfo) ProtoMessage()

func (*ColocationPuzzleInfo) Reset 

func (m *ColocationPuzzleInfo) Reset()

func (*ColocationPuzzleInfo) Size 

func (m *ColocationPuzzleInfo) Size() (n int)

func (*ColocationPuzzleInfo) String 

func (m *ColocationPuzzleInfo) String() string

func (*ColocationPuzzleInfo) Unmarshal 

func (m *ColocationPuzzleInfo) Unmarshal(dAtA []byte) error

func (*ColocationPuzzleInfo) XXX_DiscardUnknown 

func (m *ColocationPuzzleInfo) XXX_DiscardUnknown()

func (*ColocationPuzzleInfo) XXX_Marshal 

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

func (*ColocationPuzzleInfo) XXX_Merge 

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

func (*ColocationPuzzleInfo) XXX_Size 

func (m *ColocationPuzzleInfo) XXX_Size() int

func (*ColocationPuzzleInfo) XXX_Unmarshal 

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

type ContentRequest 

type ContentRequest struct {
	// TODO: This does not actually need to be repeated with each request, if we are using a connection-oriented
	// transport.
	ClientPublicKey *PublicKey `protobuf:"bytes,1,opt,name=client_public_key,json=clientPublicKey,proto3" json:"client_public_key,omitempty"`
	Path            string     `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// In bytes; the publisher can map that to chunks however it pleases.  range_begin is inclusive and range_end is
	// exclusive.  A value of zero for range_end means "the end of the object".
	RangeBegin uint64 `protobuf:"varint,5,opt,name=range_begin,json=rangeBegin,proto3" json:"range_begin,omitempty"`
	RangeEnd   uint64 `protobuf:"varint,6,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"`
	SequenceNo uint64 `protobuf:"varint,4,opt,name=sequence_no,json=sequenceNo,proto3" json:"sequence_no,omitempty"`
	// keyed by cache public key
	CacheStatus          map[string]*ContentRequest_ClientCacheStatus `` /* 182-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                     `json:"-"`
	XXX_unrecognized     []byte                                       `json:"-"`
	XXX_sizecache        int32                                        `json:"-"`
}

Client-to-publisher

func (*ContentRequest) Descriptor 

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

func (*ContentRequest) GetCacheStatus 

func (m *ContentRequest) GetCacheStatus() map[string]*ContentRequest_ClientCacheStatus

func (*ContentRequest) GetClientPublicKey 

func (m *ContentRequest) GetClientPublicKey() *PublicKey

func (*ContentRequest) GetPath 

func (m *ContentRequest) GetPath() string

func (*ContentRequest) GetRangeBegin 

func (m *ContentRequest) GetRangeBegin() uint64

func (*ContentRequest) GetRangeEnd 

func (m *ContentRequest) GetRangeEnd() uint64

func (*ContentRequest) GetSequenceNo 

func (m *ContentRequest) GetSequenceNo() uint64

func (*ContentRequest) Marshal 

func (m *ContentRequest) Marshal() (dAtA []byte, err error)

func (*ContentRequest) MarshalTo 

func (m *ContentRequest) MarshalTo(dAtA []byte) (int, error)

func (*ContentRequest) ProtoMessage 

func (*ContentRequest) ProtoMessage()

func (*ContentRequest) Reset 

func (m *ContentRequest) Reset()

func (*ContentRequest) Size 

func (m *ContentRequest) Size() (n int)

func (*ContentRequest) String 

func (m *ContentRequest) String() string

func (*ContentRequest) Unmarshal 

func (m *ContentRequest) Unmarshal(dAtA []byte) error

func (*ContentRequest) XXX_DiscardUnknown 

func (m *ContentRequest) XXX_DiscardUnknown()

func (*ContentRequest) XXX_Marshal 

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

func (*ContentRequest) XXX_Merge 

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

func (*ContentRequest) XXX_Size 

func (m *ContentRequest) XXX_Size() int

func (*ContentRequest) XXX_Unmarshal 

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

type ContentRequest_ClientCacheStatus 

type ContentRequest_ClientCacheStatus struct {
	BacklogDepth         uint64                                  `protobuf:"varint,1,opt,name=backlog_depth,json=backlogDepth,proto3" json:"backlog_depth,omitempty"`
	Status               ContentRequest_ClientCacheStatus_Status `protobuf:"varint,2,opt,name=status,proto3,enum=ccmsg.ContentRequest_ClientCacheStatus_Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                `json:"-"`
	XXX_unrecognized     []byte                                  `json:"-"`
	XXX_sizecache        int32                                   `json:"-"`
}

func (*ContentRequest_ClientCacheStatus) Descriptor 

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

func (*ContentRequest_ClientCacheStatus) GetBacklogDepth 

func (m *ContentRequest_ClientCacheStatus) GetBacklogDepth() uint64

func (*ContentRequest_ClientCacheStatus) GetStatus 

func (m *ContentRequest_ClientCacheStatus) GetStatus() ContentRequest_ClientCacheStatus_Status

func (*ContentRequest_ClientCacheStatus) Marshal 

func (m *ContentRequest_ClientCacheStatus) Marshal() (dAtA []byte, err error)

func (*ContentRequest_ClientCacheStatus) MarshalTo 

func (m *ContentRequest_ClientCacheStatus) MarshalTo(dAtA []byte) (int, error)

func (*ContentRequest_ClientCacheStatus) ProtoMessage 

func (*ContentRequest_ClientCacheStatus) ProtoMessage()

func (*ContentRequest_ClientCacheStatus) Reset 

func (m *ContentRequest_ClientCacheStatus) Reset()

func (*ContentRequest_ClientCacheStatus) Size 

func (m *ContentRequest_ClientCacheStatus) Size() (n int)

func (*ContentRequest_ClientCacheStatus) String 

func (m *ContentRequest_ClientCacheStatus) String() string

func (*ContentRequest_ClientCacheStatus) Unmarshal 

func (m *ContentRequest_ClientCacheStatus) Unmarshal(dAtA []byte) error

func (*ContentRequest_ClientCacheStatus) XXX_DiscardUnknown 

func (m *ContentRequest_ClientCacheStatus) XXX_DiscardUnknown()

func (*ContentRequest_ClientCacheStatus) XXX_Marshal 

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

func (*ContentRequest_ClientCacheStatus) XXX_Merge 

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

func (*ContentRequest_ClientCacheStatus) XXX_Size 

func (m *ContentRequest_ClientCacheStatus) XXX_Size() int

func (*ContentRequest_ClientCacheStatus) XXX_Unmarshal 

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

type ContentRequest_ClientCacheStatus_Status 

type ContentRequest_ClientCacheStatus_Status int32
const (
	// No special information from the client about the cache
	ContentRequest_ClientCacheStatus_DEFAULT ContentRequest_ClientCacheStatus_Status = 0
	// The client cannot use the cache, at this time we're not
	// discriminating why but possible reasons include cannot establish
	// TLS connections, routing failures, PMTUd black holes, or
	// potentially some form of fraud detection (but thats hard!). The
	// publisher cannot trust this enum to make value judgements about
	// the cache, but must honour it as far as delivering service to the
	// client.
	ContentRequest_ClientCacheStatus_UNUSABLE ContentRequest_ClientCacheStatus_Status = 1
)

func (ContentRequest_ClientCacheStatus_Status) EnumDescriptor 

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

func (ContentRequest_ClientCacheStatus_Status) String 

func (x ContentRequest_ClientCacheStatus_Status) String() string

type ContentResponse 

type ContentResponse struct {
	// Identifies the request that this message is a response to.
	RequestSequenceNo uint64 `protobuf:"varint,1,opt,name=request_sequence_no,json=requestSequenceNo,proto3" json:"request_sequence_no,omitempty"`
	// Exactly one of these fields may be present.
	Error                *Error          `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Bundles              []*TicketBundle `protobuf:"bytes,3,rep,name=bundles,proto3" json:"bundles,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Response to a ContentRequest.

func (*ContentResponse) Descriptor 

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

func (*ContentResponse) GetBundles 

func (m *ContentResponse) GetBundles() []*TicketBundle

func (*ContentResponse) GetError 

func (m *ContentResponse) GetError() *Error

func (*ContentResponse) GetRequestSequenceNo 

func (m *ContentResponse) GetRequestSequenceNo() uint64

func (*ContentResponse) Marshal 

func (m *ContentResponse) Marshal() (dAtA []byte, err error)

func (*ContentResponse) MarshalTo 

func (m *ContentResponse) MarshalTo(dAtA []byte) (int, error)

func (*ContentResponse) ProtoMessage 

func (*ContentResponse) ProtoMessage()

func (*ContentResponse) Reset 

func (m *ContentResponse) Reset()

func (*ContentResponse) Size 

func (m *ContentResponse) Size() (n int)

func (*ContentResponse) String 

func (m *ContentResponse) String() string

func (*ContentResponse) Unmarshal 

func (m *ContentResponse) Unmarshal(dAtA []byte) error

func (*ContentResponse) XXX_DiscardUnknown 

func (m *ContentResponse) XXX_DiscardUnknown()

func (*ContentResponse) XXX_Marshal 

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

func (*ContentResponse) XXX_Merge 

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

func (*ContentResponse) XXX_Size 

func (m *ContentResponse) XXX_Size() int

func (*ContentResponse) XXX_Unmarshal 

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

type Error 

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

func (*Error) Descriptor 

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

func (*Error) GetCode 

func (m *Error) GetCode() uint64

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) Marshal 

func (m *Error) Marshal() (dAtA []byte, err error)

func (*Error) MarshalTo 

func (m *Error) MarshalTo(dAtA []byte) (int, error)

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

func (m *Error) Size() (n int)

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

func (m *Error) Unmarshal(dAtA []byte) error

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type EscrowInfo 

type EscrowInfo struct {
	PublicKey          *PublicKey `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	PublisherPublicKey *PublicKey `protobuf:"bytes,2,opt,name=publisher_public_key,json=publisherPublicKey,proto3" json:"publisher_public_key,omitempty"`
	DrawDelay          uint64     `protobuf:"varint,3,opt,name=draw_delay,json=drawDelay,proto3" json:"draw_delay,omitempty"`
	ExpirationDelay    uint64     `protobuf:"varint,4,opt,name=expiration_delay,json=expirationDelay,proto3" json:"expiration_delay,omitempty"`
	StartBlock         uint64     `protobuf:"varint,5,opt,name=start_block,json=startBlock,proto3" json:"start_block,omitempty"`
	TicketsPerBlock    []*Segment `protobuf:"bytes,6,rep,name=tickets_per_block,json=ticketsPerBlock,proto3" json:"tickets_per_block,omitempty"`
	// If we are using block/transaction-index based IDs, then this field must not be part of what is actually committed
	// to the blockchain.
	// N.B.: Must be of length `common.EscrowIDSize`.
	Id                   []byte   `protobuf:"bytes,7,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EscrowInfo) Descriptor 

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

func (*EscrowInfo) GetDrawDelay 

func (m *EscrowInfo) GetDrawDelay() uint64

func (*EscrowInfo) GetExpirationDelay 

func (m *EscrowInfo) GetExpirationDelay() uint64

func (*EscrowInfo) GetId 

func (m *EscrowInfo) GetId() []byte

func (*EscrowInfo) GetPublicKey 

func (m *EscrowInfo) GetPublicKey() *PublicKey

func (*EscrowInfo) GetPublisherPublicKey 

func (m *EscrowInfo) GetPublisherPublicKey() *PublicKey

func (*EscrowInfo) GetStartBlock 

func (m *EscrowInfo) GetStartBlock() uint64

func (*EscrowInfo) GetTicketsPerBlock 

func (m *EscrowInfo) GetTicketsPerBlock() []*Segment

func (*EscrowInfo) Marshal 

func (m *EscrowInfo) Marshal() (dAtA []byte, err error)

func (*EscrowInfo) MarshalTo 

func (m *EscrowInfo) MarshalTo(dAtA []byte) (int, error)

func (*EscrowInfo) ProtoMessage 

func (*EscrowInfo) ProtoMessage()

func (*EscrowInfo) Reset 

func (m *EscrowInfo) Reset()

func (*EscrowInfo) Size 

func (m *EscrowInfo) Size() (n int)

func (*EscrowInfo) String 

func (m *EscrowInfo) String() string

func (*EscrowInfo) TicketsInBlock 

func (m *EscrowInfo) TicketsInBlock(block uint64) uint64

func (*EscrowInfo) TotalBlocks 

func (m *EscrowInfo) TotalBlocks() uint64

func (*EscrowInfo) TotalTickets 

func (m *EscrowInfo) TotalTickets() uint64

func (*EscrowInfo) Unmarshal 

func (m *EscrowInfo) Unmarshal(dAtA []byte) error

func (*EscrowInfo) XXX_DiscardUnknown 

func (m *EscrowInfo) XXX_DiscardUnknown()

func (*EscrowInfo) XXX_Marshal 

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

func (*EscrowInfo) XXX_Merge 

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

func (*EscrowInfo) XXX_Size 

func (m *EscrowInfo) XXX_Size() int

func (*EscrowInfo) XXX_Unmarshal 

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

type EscrowOfferRequest 

type EscrowOfferRequest struct {
	EscrowId             []byte   `protobuf:"bytes,1,opt,name=escrow_id,json=escrowId,proto3" json:"escrow_id,omitempty"`
	InnerMasterKey       []byte   `protobuf:"bytes,2,opt,name=inner_master_key,json=innerMasterKey,proto3" json:"inner_master_key,omitempty"`
	OuterMasterKey       []byte   `protobuf:"bytes,3,opt,name=outer_master_key,json=outerMasterKey,proto3" json:"outer_master_key,omitempty"`
	Slots                uint64   `protobuf:"varint,4,opt,name=slots,proto3" json:"slots,omitempty"`
	PublisherAddr        string   `protobuf:"bytes,5,opt,name=publisher_addr,json=publisherAddr,proto3" json:"publisher_addr,omitempty"`
	StartBlock           uint64   `protobuf:"varint,6,opt,name=start_block,json=startBlock,proto3" json:"start_block,omitempty"`
	EndBlock             uint64   `protobuf:"varint,7,opt,name=end_block,json=endBlock,proto3" json:"end_block,omitempty"`
	PublicKey            []byte   `protobuf:"bytes,8,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	PrivateKey           []byte   `protobuf:"bytes,9,opt,name=private_key,json=privateKey,proto3" json:"private_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EscrowOfferRequest) Descriptor 

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

func (*EscrowOfferRequest) GetEndBlock 

func (m *EscrowOfferRequest) GetEndBlock() uint64

func (*EscrowOfferRequest) GetEscrowId 

func (m *EscrowOfferRequest) GetEscrowId() []byte

func (*EscrowOfferRequest) GetInnerMasterKey 

func (m *EscrowOfferRequest) GetInnerMasterKey() []byte

func (*EscrowOfferRequest) GetOuterMasterKey 

func (m *EscrowOfferRequest) GetOuterMasterKey() []byte

func (*EscrowOfferRequest) GetPrivateKey 

func (m *EscrowOfferRequest) GetPrivateKey() []byte

func (*EscrowOfferRequest) GetPublicKey 

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

func (*EscrowOfferRequest) GetPublisherAddr 

func (m *EscrowOfferRequest) GetPublisherAddr() string

func (*EscrowOfferRequest) GetSlots 

func (m *EscrowOfferRequest) GetSlots() uint64

func (*EscrowOfferRequest) GetStartBlock 

func (m *EscrowOfferRequest) GetStartBlock() uint64

func (*EscrowOfferRequest) Marshal 

func (m *EscrowOfferRequest) Marshal() (dAtA []byte, err error)

func (*EscrowOfferRequest) MarshalTo 

func (m *EscrowOfferRequest) MarshalTo(dAtA []byte) (int, error)

func (*EscrowOfferRequest) ProtoMessage 

func (*EscrowOfferRequest) ProtoMessage()

func (*EscrowOfferRequest) Reset 

func (m *EscrowOfferRequest) Reset()

func (*EscrowOfferRequest) Size 

func (m *EscrowOfferRequest) Size() (n int)

func (*EscrowOfferRequest) String 

func (m *EscrowOfferRequest) String() string

func (*EscrowOfferRequest) Unmarshal 

func (m *EscrowOfferRequest) Unmarshal(dAtA []byte) error

func (*EscrowOfferRequest) XXX_DiscardUnknown 

func (m *EscrowOfferRequest) XXX_DiscardUnknown()

func (*EscrowOfferRequest) XXX_Marshal 

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

func (*EscrowOfferRequest) XXX_Merge 

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

func (*EscrowOfferRequest) XXX_Size 

func (m *EscrowOfferRequest) XXX_Size() int

func (*EscrowOfferRequest) XXX_Unmarshal 

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

type EscrowOfferResponse 

type EscrowOfferResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

XXX: return a response or error if we reject the escrow?

func (*EscrowOfferResponse) Descriptor 

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

func (*EscrowOfferResponse) Marshal 

func (m *EscrowOfferResponse) Marshal() (dAtA []byte, err error)

func (*EscrowOfferResponse) MarshalTo 

func (m *EscrowOfferResponse) MarshalTo(dAtA []byte) (int, error)

func (*EscrowOfferResponse) ProtoMessage 

func (*EscrowOfferResponse) ProtoMessage()

func (*EscrowOfferResponse) Reset 

func (m *EscrowOfferResponse) Reset()

func (*EscrowOfferResponse) Size 

func (m *EscrowOfferResponse) Size() (n int)

func (*EscrowOfferResponse) String 

func (m *EscrowOfferResponse) String() string

func (*EscrowOfferResponse) Unmarshal 

func (m *EscrowOfferResponse) Unmarshal(dAtA []byte) error

func (*EscrowOfferResponse) XXX_DiscardUnknown 

func (m *EscrowOfferResponse) XXX_DiscardUnknown()

func (*EscrowOfferResponse) XXX_Marshal 

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

func (*EscrowOfferResponse) XXX_Merge 

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

func (*EscrowOfferResponse) XXX_Size 

func (m *EscrowOfferResponse) XXX_Size() int

func (*EscrowOfferResponse) XXX_Unmarshal 

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

type FaucetClient 

type FaucetClient interface {
	GetCoins(ctx context.Context, in *GetCoinsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

FaucetClient is the client API for Faucet service.

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

func NewFaucetClient 

func NewFaucetClient(cc *grpc.ClientConn) FaucetClient

type FaucetServer 

type FaucetServer interface {
	GetCoins(context.Context, *GetCoinsRequest) (*empty.Empty, error)
}

FaucetServer is the server API for Faucet service.

type GetBlocksRequest 

type GetBlocksRequest struct {
	StartDepth           int64    `protobuf:"varint,1,opt,name=start_depth,json=startDepth,proto3" json:"start_depth,omitempty"`
	Limit                uint64   `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	PageToken            []byte   `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetBlocksRequest wraps up the requests for blocks. To reliably get all blocks (e.g. replicating the entire dataset), start with a start-depth of 0 and increase it; only blocks higher than or equal to start_depth are returned up to limit. To get more blocks than requested limit at a given start_depth, use the next_page_token to offset into the dataset. Blocks are returned in height and block id ascending order, unless start_depth is -1, in which case blocks are returned in height and block id descending order.

Returning blocks in descending order is a blockexplorer support feature as well as being useful mechanism for determining whether a replica is up to date; long term block explorer will likely switch to replicating rather than having the ledger support the browser-friendly index, but as a short term priority we want to deliver the explorer to people right now. tl;dr: please do not make the ledger super complicated: add more features by giving the explorer a cache DB of its own where it can derive appropriate indices (such as a projected tree index to show branches of the chain).

func (*GetBlocksRequest) Descriptor 

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

func (*GetBlocksRequest) GetLimit 

func (m *GetBlocksRequest) GetLimit() uint64

func (*GetBlocksRequest) GetPageToken 

func (m *GetBlocksRequest) GetPageToken() []byte

func (*GetBlocksRequest) GetStartDepth 

func (m *GetBlocksRequest) GetStartDepth() int64

func (*GetBlocksRequest) Marshal 

func (m *GetBlocksRequest) Marshal() (dAtA []byte, err error)

func (*GetBlocksRequest) MarshalTo 

func (m *GetBlocksRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetBlocksRequest) ProtoMessage 

func (*GetBlocksRequest) ProtoMessage()

func (*GetBlocksRequest) Reset 

func (m *GetBlocksRequest) Reset()

func (*GetBlocksRequest) Size 

func (m *GetBlocksRequest) Size() (n int)

func (*GetBlocksRequest) String 

func (m *GetBlocksRequest) String() string

func (*GetBlocksRequest) Unmarshal 

func (m *GetBlocksRequest) Unmarshal(dAtA []byte) error

func (*GetBlocksRequest) XXX_DiscardUnknown 

func (m *GetBlocksRequest) XXX_DiscardUnknown()

func (*GetBlocksRequest) XXX_Marshal 

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

func (*GetBlocksRequest) XXX_Merge 

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

func (*GetBlocksRequest) XXX_Size 

func (m *GetBlocksRequest) XXX_Size() int

func (*GetBlocksRequest) XXX_Unmarshal 

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

type GetBlocksResponse 

type GetBlocksResponse struct {
	Blocks []*ledger.Block `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// Opaque tokens for walking blocks forward/backward
	NextPageToken        []byte   `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	PrevPageToken        []byte   `protobuf:"bytes,3,opt,name=prev_page_token,json=prevPageToken,proto3" json:"prev_page_token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetBlocksResponse) Descriptor 

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

func (*GetBlocksResponse) GetBlocks 

func (m *GetBlocksResponse) GetBlocks() []*ledger.Block

func (*GetBlocksResponse) GetNextPageToken 

func (m *GetBlocksResponse) GetNextPageToken() []byte

func (*GetBlocksResponse) GetPrevPageToken 

func (m *GetBlocksResponse) GetPrevPageToken() []byte

func (*GetBlocksResponse) Marshal 

func (m *GetBlocksResponse) Marshal() (dAtA []byte, err error)

func (*GetBlocksResponse) MarshalTo 

func (m *GetBlocksResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetBlocksResponse) ProtoMessage 

func (*GetBlocksResponse) ProtoMessage()

func (*GetBlocksResponse) Reset 

func (m *GetBlocksResponse) Reset()

func (*GetBlocksResponse) Size 

func (m *GetBlocksResponse) Size() (n int)

func (*GetBlocksResponse) String 

func (m *GetBlocksResponse) String() string

func (*GetBlocksResponse) Unmarshal 

func (m *GetBlocksResponse) Unmarshal(dAtA []byte) error

func (*GetBlocksResponse) XXX_DiscardUnknown 

func (m *GetBlocksResponse) XXX_DiscardUnknown()

func (*GetBlocksResponse) XXX_Marshal 

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

func (*GetBlocksResponse) XXX_Merge 

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

func (*GetBlocksResponse) XXX_Size 

func (m *GetBlocksResponse) XXX_Size() int

func (*GetBlocksResponse) XXX_Unmarshal 

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

type GetCoinsRequest 

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

func (*GetCoinsRequest) Descriptor 

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

func (*GetCoinsRequest) GetAddress 

func (m *GetCoinsRequest) GetAddress() string

func (*GetCoinsRequest) Marshal 

func (m *GetCoinsRequest) Marshal() (dAtA []byte, err error)

func (*GetCoinsRequest) MarshalTo 

func (m *GetCoinsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetCoinsRequest) ProtoMessage 

func (*GetCoinsRequest) ProtoMessage()

func (*GetCoinsRequest) Reset 

func (m *GetCoinsRequest) Reset()

func (*GetCoinsRequest) Size 

func (m *GetCoinsRequest) Size() (n int)

func (*GetCoinsRequest) String 

func (m *GetCoinsRequest) String() string

func (*GetCoinsRequest) Unmarshal 

func (m *GetCoinsRequest) Unmarshal(dAtA []byte) error

func (*GetCoinsRequest) XXX_DiscardUnknown 

func (m *GetCoinsRequest) XXX_DiscardUnknown()

func (*GetCoinsRequest) XXX_Marshal 

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

func (*GetCoinsRequest) XXX_Merge 

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

func (*GetCoinsRequest) XXX_Size 

func (m *GetCoinsRequest) XXX_Size() int

func (*GetCoinsRequest) XXX_Unmarshal 

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

type LedgerClient 

type LedgerClient interface {
	PostTransaction(ctx context.Context, in *PostTransactionRequest, opts ...grpc.CallOption) (*PostTransactionResponse, error)
	GetBlocks(ctx context.Context, in *GetBlocksRequest, opts ...grpc.CallOption) (*GetBlocksResponse, error)
}

LedgerClient is the client API for Ledger service.

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

func NewLedgerClient 

func NewLedgerClient(cc *grpc.ClientConn) LedgerClient

type LedgerServer 

type LedgerServer interface {
	PostTransaction(context.Context, *PostTransactionRequest) (*PostTransactionResponse, error)
	GetBlocks(context.Context, *GetBlocksRequest) (*GetBlocksResponse, error)
}

LedgerServer is the server API for Ledger service.

type NetworkAddress 

type NetworkAddress struct {
	// XXX: Or, we could represent this as an AF_* constant and a []byte addr.
	Inetaddr             []byte   `protobuf:"bytes,1,opt,name=inetaddr,proto3" json:"inetaddr,omitempty"`
	Inet6Addr            []byte   `protobuf:"bytes,2,opt,name=inet6addr,proto3" json:"inet6addr,omitempty"`
	Port                 uint32   `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

XXX: Is this a good name if this message includes a port number?

func (*NetworkAddress) ConnectionString 

func (a *NetworkAddress) ConnectionString() string

func (*NetworkAddress) Descriptor 

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

func (*NetworkAddress) GetInet6Addr 

func (m *NetworkAddress) GetInet6Addr() []byte

func (*NetworkAddress) GetInetaddr 

func (m *NetworkAddress) GetInetaddr() []byte

func (*NetworkAddress) GetPort 

func (m *NetworkAddress) GetPort() uint32

func (*NetworkAddress) Marshal 

func (m *NetworkAddress) Marshal() (dAtA []byte, err error)

func (*NetworkAddress) MarshalTo 

func (m *NetworkAddress) MarshalTo(dAtA []byte) (int, error)

func (*NetworkAddress) ProtoMessage 

func (*NetworkAddress) ProtoMessage()

func (*NetworkAddress) Reset 

func (m *NetworkAddress) Reset()

func (*NetworkAddress) Size 

func (m *NetworkAddress) Size() (n int)

func (*NetworkAddress) String 

func (m *NetworkAddress) String() string

func (*NetworkAddress) Unmarshal 

func (m *NetworkAddress) Unmarshal(dAtA []byte) error

func (*NetworkAddress) XXX_DiscardUnknown 

func (m *NetworkAddress) XXX_DiscardUnknown()

func (*NetworkAddress) XXX_Marshal 

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

func (*NetworkAddress) XXX_Merge 

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

func (*NetworkAddress) XXX_Size 

func (m *NetworkAddress) XXX_Size() int

func (*NetworkAddress) XXX_Unmarshal 

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

type NodeBootstrapdClient 

type NodeBootstrapdClient interface {
	AnnounceCache(ctx context.Context, in *CacheAnnounceRequest, opts ...grpc.CallOption) (*CacheAnnounceResponse, error)
	FetchCaches(ctx context.Context, in *CacheFetchRequest, opts ...grpc.CallOption) (*CacheFetchResponse, error)
}

NodeBootstrapdClient is the client API for NodeBootstrapd service.

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

func NewNodeBootstrapdClient 

func NewNodeBootstrapdClient(cc *grpc.ClientConn) NodeBootstrapdClient

type NodeBootstrapdServer 

type NodeBootstrapdServer interface {
	AnnounceCache(context.Context, *CacheAnnounceRequest) (*CacheAnnounceResponse, error)
	FetchCaches(context.Context, *CacheFetchRequest) (*CacheFetchResponse, error)
}

NodeBootstrapdServer is the server API for NodeBootstrapd service.

type ObjectMetadata 

type ObjectMetadata struct {
	ObjectSize uint64 `protobuf:"varint,1,opt,name=object_size,json=objectSize,proto3" json:"object_size,omitempty"`
	ChunkSize  uint64 `protobuf:"varint,2,opt,name=chunk_size,json=chunkSize,proto3" json:"chunk_size,omitempty"`
	// Passed through by publisher from HTTP upstream.
	Etag         []byte `protobuf:"bytes,4,opt,name=etag,proto3" json:"etag,omitempty"`
	LastModified string `protobuf:"bytes,5,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"`
	// Decided by publisher based on HTTP headers.
	CacheExpiration       string   `protobuf:"bytes,6,opt,name=cache_expiration,json=cacheExpiration,proto3" json:"cache_expiration,omitempty"`
	MinimumBacklogDepth   uint32   `protobuf:"varint,7,opt,name=minimum_backlog_depth,json=minimumBacklogDepth,proto3" json:"minimum_backlog_depth,omitempty"`
	BundleRequestInterval uint32   `` /* 127-byte string literal not displayed */
	XXX_NoUnkeyedLiteral  struct{} `json:"-"`
	XXX_unrecognized      []byte   `json:"-"`
	XXX_sizecache         int32    `json:"-"`
}

TODO: this struct is also used at the cache, but most of these fields are irrelevant for the cache and only relevant for the publisher

func (*ObjectMetadata) ChunkCount 

func (m *ObjectMetadata) ChunkCount() uint64

func (*ObjectMetadata) Descriptor 

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

func (*ObjectMetadata) GetBundleRequestInterval 

func (m *ObjectMetadata) GetBundleRequestInterval() uint32

func (*ObjectMetadata) GetCacheExpiration 

func (m *ObjectMetadata) GetCacheExpiration() string

func (*ObjectMetadata) GetChunkSize 

func (m *ObjectMetadata) GetChunkSize() uint64

func (*ObjectMetadata) GetEtag 

func (m *ObjectMetadata) GetEtag() []byte

func (*ObjectMetadata) GetLastModified 

func (m *ObjectMetadata) GetLastModified() string

func (*ObjectMetadata) GetMinimumBacklogDepth 

func (m *ObjectMetadata) GetMinimumBacklogDepth() uint32

func (*ObjectMetadata) GetObjectSize 

func (m *ObjectMetadata) GetObjectSize() uint64

func (*ObjectMetadata) Marshal 

func (m *ObjectMetadata) Marshal() (dAtA []byte, err error)

func (*ObjectMetadata) MarshalTo 

func (m *ObjectMetadata) MarshalTo(dAtA []byte) (int, error)

func (*ObjectMetadata) ProtoMessage 

func (*ObjectMetadata) ProtoMessage()

func (*ObjectMetadata) Reset 

func (m *ObjectMetadata) Reset()

func (*ObjectMetadata) Size 

func (m *ObjectMetadata) Size() (n int)

func (*ObjectMetadata) String 

func (m *ObjectMetadata) String() string

func (*ObjectMetadata) Unmarshal 

func (m *ObjectMetadata) Unmarshal(dAtA []byte) error

func (*ObjectMetadata) XXX_DiscardUnknown 

func (m *ObjectMetadata) XXX_DiscardUnknown()

func (*ObjectMetadata) XXX_Marshal 

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

func (*ObjectMetadata) XXX_Merge 

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

func (*ObjectMetadata) XXX_Size 

func (m *ObjectMetadata) XXX_Size() int

func (*ObjectMetadata) XXX_Unmarshal 

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

type PingCacheRequest 

type PingCacheRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingCacheRequest) Descriptor 

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

func (*PingCacheRequest) Marshal 

func (m *PingCacheRequest) Marshal() (dAtA []byte, err error)

func (*PingCacheRequest) MarshalTo 

func (m *PingCacheRequest) MarshalTo(dAtA []byte) (int, error)

func (*PingCacheRequest) ProtoMessage 

func (*PingCacheRequest) ProtoMessage()

func (*PingCacheRequest) Reset 

func (m *PingCacheRequest) Reset()

func (*PingCacheRequest) Size 

func (m *PingCacheRequest) Size() (n int)

func (*PingCacheRequest) String 

func (m *PingCacheRequest) String() string

func (*PingCacheRequest) Unmarshal 

func (m *PingCacheRequest) Unmarshal(dAtA []byte) error

func (*PingCacheRequest) XXX_DiscardUnknown 

func (m *PingCacheRequest) XXX_DiscardUnknown()

func (*PingCacheRequest) XXX_Marshal 

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

func (*PingCacheRequest) XXX_Merge 

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

func (*PingCacheRequest) XXX_Size 

func (m *PingCacheRequest) XXX_Size() int

func (*PingCacheRequest) XXX_Unmarshal 

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

type PingCacheResponse 

type PingCacheResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingCacheResponse) Descriptor 

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

func (*PingCacheResponse) Marshal 

func (m *PingCacheResponse) Marshal() (dAtA []byte, err error)

func (*PingCacheResponse) MarshalTo 

func (m *PingCacheResponse) MarshalTo(dAtA []byte) (int, error)

func (*PingCacheResponse) ProtoMessage 

func (*PingCacheResponse) ProtoMessage()

func (*PingCacheResponse) Reset 

func (m *PingCacheResponse) Reset()

func (*PingCacheResponse) Size 

func (m *PingCacheResponse) Size() (n int)

func (*PingCacheResponse) String 

func (m *PingCacheResponse) String() string

func (*PingCacheResponse) Unmarshal 

func (m *PingCacheResponse) Unmarshal(dAtA []byte) error

func (*PingCacheResponse) XXX_DiscardUnknown 

func (m *PingCacheResponse) XXX_DiscardUnknown()

func (*PingCacheResponse) XXX_Marshal 

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

func (*PingCacheResponse) XXX_Merge 

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

func (*PingCacheResponse) XXX_Size 

func (m *PingCacheResponse) XXX_Size() int

func (*PingCacheResponse) XXX_Unmarshal 

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

type PostTransactionRequest 

type PostTransactionRequest struct {
	Tx                   github_com_cachecashproject_go_cachecash_ledger.Transaction `protobuf:"bytes,1,opt,name=tx,proto3,customtype=github.com/cachecashproject/go-cachecash/ledger.Transaction" json:"tx"`
	XXX_NoUnkeyedLiteral struct{}                                                    `json:"-"`
	XXX_unrecognized     []byte                                                      `json:"-"`
	XXX_sizecache        int32                                                       `json:"-"`
}

func (*PostTransactionRequest) Descriptor 

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

func (*PostTransactionRequest) Marshal 

func (m *PostTransactionRequest) Marshal() (dAtA []byte, err error)

func (*PostTransactionRequest) MarshalTo 

func (m *PostTransactionRequest) MarshalTo(dAtA []byte) (int, error)

func (*PostTransactionRequest) ProtoMessage 

func (*PostTransactionRequest) ProtoMessage()

func (*PostTransactionRequest) Reset 

func (m *PostTransactionRequest) Reset()

func (*PostTransactionRequest) Size 

func (m *PostTransactionRequest) Size() (n int)

func (*PostTransactionRequest) String 

func (m *PostTransactionRequest) String() string

func (*PostTransactionRequest) Unmarshal 

func (m *PostTransactionRequest) Unmarshal(dAtA []byte) error

func (*PostTransactionRequest) XXX_DiscardUnknown 

func (m *PostTransactionRequest) XXX_DiscardUnknown()

func (*PostTransactionRequest) XXX_Marshal 

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

func (*PostTransactionRequest) XXX_Merge 

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

func (*PostTransactionRequest) XXX_Size 

func (m *PostTransactionRequest) XXX_Size() int

func (*PostTransactionRequest) XXX_Unmarshal 

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

type PostTransactionResponse 

type PostTransactionResponse struct {
	Error                *Error   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PostTransactionResponse) Descriptor 

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

func (*PostTransactionResponse) GetError 

func (m *PostTransactionResponse) GetError() *Error

func (*PostTransactionResponse) Marshal 

func (m *PostTransactionResponse) Marshal() (dAtA []byte, err error)

func (*PostTransactionResponse) MarshalTo 

func (m *PostTransactionResponse) MarshalTo(dAtA []byte) (int, error)

func (*PostTransactionResponse) ProtoMessage 

func (*PostTransactionResponse) ProtoMessage()

func (*PostTransactionResponse) Reset 

func (m *PostTransactionResponse) Reset()

func (*PostTransactionResponse) Size 

func (m *PostTransactionResponse) Size() (n int)

func (*PostTransactionResponse) String 

func (m *PostTransactionResponse) String() string

func (*PostTransactionResponse) Unmarshal 

func (m *PostTransactionResponse) Unmarshal(dAtA []byte) error

func (*PostTransactionResponse) XXX_DiscardUnknown 

func (m *PostTransactionResponse) XXX_DiscardUnknown()

func (*PostTransactionResponse) XXX_Marshal 

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

func (*PostTransactionResponse) XXX_Merge 

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

func (*PostTransactionResponse) XXX_Size 

func (m *PostTransactionResponse) XXX_Size() int

func (*PostTransactionResponse) XXX_Unmarshal 

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

type PublicKey 

type PublicKey struct {
	// TODO: Add an enum for key type.
	PublicKey            []byte   `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PublicKey) Descriptor 

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

func (*PublicKey) GetPublicKey 

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

func (*PublicKey) Marshal 

func (m *PublicKey) Marshal() (dAtA []byte, err error)

func (*PublicKey) MarshalTo 

func (m *PublicKey) MarshalTo(dAtA []byte) (int, error)

func (*PublicKey) ProtoMessage 

func (*PublicKey) ProtoMessage()

func (*PublicKey) Reset 

func (m *PublicKey) Reset()

func (*PublicKey) Size 

func (m *PublicKey) Size() (n int)

func (*PublicKey) String 

func (m *PublicKey) String() string

func (*PublicKey) Unmarshal 

func (m *PublicKey) Unmarshal(dAtA []byte) error

func (*PublicKey) XXX_DiscardUnknown 

func (m *PublicKey) XXX_DiscardUnknown()

func (*PublicKey) XXX_Marshal 

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

func (*PublicKey) XXX_Merge 

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

func (*PublicKey) XXX_Size 

func (m *PublicKey) XXX_Size() int

func (*PublicKey) XXX_Unmarshal 

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

type PublisherCacheClient 

type PublisherCacheClient interface {
	OfferEscrow(ctx context.Context, in *EscrowOfferRequest, opts ...grpc.CallOption) (*EscrowOfferResponse, error)
	PingCache(ctx context.Context, in *PingCacheRequest, opts ...grpc.CallOption) (*PingCacheResponse, error)
}

PublisherCacheClient is the client API for PublisherCache service.

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

func NewPublisherCacheClient 

func NewPublisherCacheClient(cc *grpc.ClientConn) PublisherCacheClient

type PublisherCacheServer 

type PublisherCacheServer interface {
	OfferEscrow(context.Context, *EscrowOfferRequest) (*EscrowOfferResponse, error)
	PingCache(context.Context, *PingCacheRequest) (*PingCacheResponse, error)
}

PublisherCacheServer is the server API for PublisherCache service.

type Segment 

type Segment struct {
	Length               uint64   `protobuf:"varint,1,opt,name=length,proto3" json:"length,omitempty"`
	Value                uint64   `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Segment) Descriptor 

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

func (*Segment) GetLength 

func (m *Segment) GetLength() uint64

func (*Segment) GetValue 

func (m *Segment) GetValue() uint64

func (*Segment) Marshal 

func (m *Segment) Marshal() (dAtA []byte, err error)

func (*Segment) MarshalTo 

func (m *Segment) MarshalTo(dAtA []byte) (int, error)

func (*Segment) ProtoMessage 

func (*Segment) ProtoMessage()

func (*Segment) Reset 

func (m *Segment) Reset()

func (*Segment) Size 

func (m *Segment) Size() (n int)

func (*Segment) String 

func (m *Segment) String() string

func (*Segment) Unmarshal 

func (m *Segment) Unmarshal(dAtA []byte) error

func (*Segment) XXX_DiscardUnknown 

func (m *Segment) XXX_DiscardUnknown()

func (*Segment) XXX_Marshal 

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

func (*Segment) XXX_Merge 

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

func (*Segment) XXX_Size 

func (m *Segment) XXX_Size() int

func (*Segment) XXX_Unmarshal 

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

type TicketBundle 

type TicketBundle struct {
	Remainder         *TicketBundleRemainder `protobuf:"bytes,1,opt,name=remainder,proto3" json:"remainder,omitempty"`
	TicketRequest     []*TicketRequest       `protobuf:"bytes,5,rep,name=ticket_request,json=ticketRequest,proto3" json:"ticket_request,omitempty"`
	TicketL1          []*TicketL1            `protobuf:"bytes,6,rep,name=ticket_l1,json=ticketL1,proto3" json:"ticket_l1,omitempty"`
	EncryptedTicketL2 []byte                 `protobuf:"bytes,10,opt,name=encrypted_ticket_l2,json=encryptedTicketL2,proto3" json:"encrypted_ticket_l2,omitempty"`
	BatchSig          *BatchSignature        `protobuf:"bytes,8,opt,name=batch_sig,json=batchSig,proto3" json:"batch_sig,omitempty"`
	BundleSignerCert  *Certificate           `protobuf:"bytes,11,opt,name=bundle_signer_cert,json=bundleSignerCert,proto3" json:"bundle_signer_cert,omitempty"`
	// This field contains connection information for the caches mentioned in the ticket requests.
	// (XXX: There's not any particularly great/specific reason why this couldn't be covered by the hash.)
	CacheInfo            []*CacheInfo    `protobuf:"bytes,9,rep,name=cache_info,json=cacheInfo,proto3" json:"cache_info,omitempty"`
	Metadata             *ObjectMetadata `protobuf:"bytes,12,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*TicketBundle) BuildClientCacheRequest 

func (m *TicketBundle) BuildClientCacheRequest(subMsg proto.Message) (*ClientCacheRequest, error)

func (*TicketBundle) CanonicalDigest 

func (m *TicketBundle) CanonicalDigest() []byte

XXX: Should we enforce validation of this message, and have CanonicalDigest return an error if the message is not valid (instead of silently return a bad digest))?

func (*TicketBundle) Descriptor 

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

func (*TicketBundle) GetBatchSig 

func (m *TicketBundle) GetBatchSig() *BatchSignature

func (*TicketBundle) GetBundleSignerCert 

func (m *TicketBundle) GetBundleSignerCert() *Certificate

func (*TicketBundle) GetCacheInfo 

func (m *TicketBundle) GetCacheInfo() []*CacheInfo

func (*TicketBundle) GetEncryptedTicketL2 

func (m *TicketBundle) GetEncryptedTicketL2() []byte

func (*TicketBundle) GetMetadata 

func (m *TicketBundle) GetMetadata() *ObjectMetadata

func (*TicketBundle) GetRemainder 

func (m *TicketBundle) GetRemainder() *TicketBundleRemainder

func (*TicketBundle) GetSubdigests 

func (m *TicketBundle) GetSubdigests() *TicketBundleSubdigests

func (*TicketBundle) GetTicketL1 

func (m *TicketBundle) GetTicketL1() []*TicketL1

func (*TicketBundle) GetTicketRequest 

func (m *TicketBundle) GetTicketRequest() []*TicketRequest

func (*TicketBundle) Marshal 

func (m *TicketBundle) Marshal() (dAtA []byte, err error)

func (*TicketBundle) MarshalTo 

func (m *TicketBundle) MarshalTo(dAtA []byte) (int, error)

func (*TicketBundle) ProtoMessage 

func (*TicketBundle) ProtoMessage()

func (*TicketBundle) Reset 

func (m *TicketBundle) Reset()

func (*TicketBundle) Size 

func (m *TicketBundle) Size() (n int)

func (*TicketBundle) String 

func (m *TicketBundle) String() string

func (*TicketBundle) Unmarshal 

func (m *TicketBundle) Unmarshal(dAtA []byte) error

func (*TicketBundle) XXX_DiscardUnknown 

func (m *TicketBundle) XXX_DiscardUnknown()

func (*TicketBundle) XXX_Marshal 

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

func (*TicketBundle) XXX_Merge 

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

func (*TicketBundle) XXX_Size 

func (m *TicketBundle) XXX_Size() int

func (*TicketBundle) XXX_Unmarshal 

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

type TicketBundleRemainder 

type TicketBundleRemainder struct {
	// XXX: Is having the request-sequence number as part of the input to the keyed PRF important?
	// TODO: Remove this in favor of the field in the ContentResponse envelope.
	RequestSequenceNo    uint64                `protobuf:"varint,2,opt,name=request_sequence_no,json=requestSequenceNo,proto3" json:"request_sequence_no,omitempty"`
	EscrowId             []byte                `protobuf:"bytes,1,opt,name=escrow_id,json=escrowId,proto3" json:"escrow_id,omitempty"`
	ObjectId             []byte                `protobuf:"bytes,3,opt,name=object_id,json=objectId,proto3" json:"object_id,omitempty"`
	PuzzleInfo           *ColocationPuzzleInfo `protobuf:"bytes,7,opt,name=puzzle_info,json=puzzleInfo,proto3" json:"puzzle_info,omitempty"`
	ClientPublicKey      *PublicKey            `protobuf:"bytes,8,opt,name=client_public_key,json=clientPublicKey,proto3" json:"client_public_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

XXX: This needs a better name.

func (*TicketBundleRemainder) CanonicalDigest 

func (m *TicketBundleRemainder) CanonicalDigest() []byte

XXX: Update this once the message contents are more stable!

func (*TicketBundleRemainder) Descriptor 

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

func (*TicketBundleRemainder) GetClientPublicKey 

func (m *TicketBundleRemainder) GetClientPublicKey() *PublicKey

func (*TicketBundleRemainder) GetEscrowId 

func (m *TicketBundleRemainder) GetEscrowId() []byte

func (*TicketBundleRemainder) GetObjectId 

func (m *TicketBundleRemainder) GetObjectId() []byte

func (*TicketBundleRemainder) GetPuzzleInfo 

func (m *TicketBundleRemainder) GetPuzzleInfo() *ColocationPuzzleInfo

func (*TicketBundleRemainder) GetRequestSequenceNo 

func (m *TicketBundleRemainder) GetRequestSequenceNo() uint64

func (*TicketBundleRemainder) Marshal 

func (m *TicketBundleRemainder) Marshal() (dAtA []byte, err error)

func (*TicketBundleRemainder) MarshalTo 

func (m *TicketBundleRemainder) MarshalTo(dAtA []byte) (int, error)

func (*TicketBundleRemainder) ProtoMessage 

func (*TicketBundleRemainder) ProtoMessage()

func (*TicketBundleRemainder) Reset 

func (m *TicketBundleRemainder) Reset()

func (*TicketBundleRemainder) Size 

func (m *TicketBundleRemainder) Size() (n int)

func (*TicketBundleRemainder) String 

func (m *TicketBundleRemainder) String() string

func (*TicketBundleRemainder) Unmarshal 

func (m *TicketBundleRemainder) Unmarshal(dAtA []byte) error

func (*TicketBundleRemainder) XXX_DiscardUnknown 

func (m *TicketBundleRemainder) XXX_DiscardUnknown()

func (*TicketBundleRemainder) XXX_Marshal 

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

func (*TicketBundleRemainder) XXX_Merge 

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

func (*TicketBundleRemainder) XXX_Size 

func (m *TicketBundleRemainder) XXX_Size() int

func (*TicketBundleRemainder) XXX_Unmarshal 

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

type TicketBundleSubdigests 

type TicketBundleSubdigests struct {
	TicketRequestDigest     [][]byte `protobuf:"bytes,1,rep,name=ticket_request_digest,json=ticketRequestDigest,proto3" json:"ticket_request_digest,omitempty"`
	TicketL1Digest          [][]byte `protobuf:"bytes,2,rep,name=ticket_l1_digest,json=ticketL1Digest,proto3" json:"ticket_l1_digest,omitempty"`
	EncryptedTicketL2Digest []byte   `` /* 134-byte string literal not displayed */
	RemainderDigest         []byte   `protobuf:"bytes,4,opt,name=remainder_digest,json=remainderDigest,proto3" json:"remainder_digest,omitempty"`
	XXX_NoUnkeyedLiteral    struct{} `json:"-"`
	XXX_unrecognized        []byte   `json:"-"`
	XXX_sizecache           int32    `json:"-"`
}

Contains enough data to let a cache recompute/verify the ticket-bundle digest.

func (*TicketBundleSubdigests) CanonicalDigest 

func (m *TicketBundleSubdigests) CanonicalDigest() []byte

func (*TicketBundleSubdigests) ContainsTicketL1Digest 

func (m *TicketBundleSubdigests) ContainsTicketL1Digest(d []byte) bool

func (*TicketBundleSubdigests) ContainsTicketRequestDigest 

func (m *TicketBundleSubdigests) ContainsTicketRequestDigest(d []byte) bool

func (*TicketBundleSubdigests) Descriptor 

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

func (*TicketBundleSubdigests) GetEncryptedTicketL2Digest 

func (m *TicketBundleSubdigests) GetEncryptedTicketL2Digest() []byte

func (*TicketBundleSubdigests) GetRemainderDigest 

func (m *TicketBundleSubdigests) GetRemainderDigest() []byte

func (*TicketBundleSubdigests) GetTicketL1Digest 

func (m *TicketBundleSubdigests) GetTicketL1Digest() [][]byte

func (*TicketBundleSubdigests) GetTicketRequestDigest 

func (m *TicketBundleSubdigests) GetTicketRequestDigest() [][]byte

func (*TicketBundleSubdigests) Marshal 

func (m *TicketBundleSubdigests) Marshal() (dAtA []byte, err error)

func (*TicketBundleSubdigests) MarshalTo 

func (m *TicketBundleSubdigests) MarshalTo(dAtA []byte) (int, error)

func (*TicketBundleSubdigests) ProtoMessage 

func (*TicketBundleSubdigests) ProtoMessage()

func (*TicketBundleSubdigests) Reset 

func (m *TicketBundleSubdigests) Reset()

func (*TicketBundleSubdigests) Size 

func (m *TicketBundleSubdigests) Size() (n int)

func (*TicketBundleSubdigests) String 

func (m *TicketBundleSubdigests) String() string

func (*TicketBundleSubdigests) Unmarshal 

func (m *TicketBundleSubdigests) Unmarshal(dAtA []byte) error

func (*TicketBundleSubdigests) XXX_DiscardUnknown 

func (m *TicketBundleSubdigests) XXX_DiscardUnknown()

func (*TicketBundleSubdigests) XXX_Marshal 

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

func (*TicketBundleSubdigests) XXX_Merge 

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

func (*TicketBundleSubdigests) XXX_Size 

func (m *TicketBundleSubdigests) XXX_Size() int

func (*TicketBundleSubdigests) XXX_Unmarshal 

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

type TicketL1 

type TicketL1 struct {
	// PublicKey escrow_public_key = 1;
	TicketNo uint64 `protobuf:"varint,2,opt,name=ticket_no,json=ticketNo,proto3" json:"ticket_no,omitempty"`
	// XXX: This is *also* duplicated between TicketL1 and TicketRequest.
	CachePublicKey *PublicKey `protobuf:"bytes,3,opt,name=cache_public_key,json=cachePublicKey,proto3" json:"cache_public_key,omitempty"`
	// XXX: This is duplicated between this message and the TicketRequest, which could probably be avoided.  However,
	// the cache does need to be able to work out which block-index the L1 ticket corresponds to so that it can derive
	// the right outer key to give to the client.
	ChunkIdx             uint64   `protobuf:"varint,4,opt,name=chunk_idx,json=chunkIdx,proto3" json:"chunk_idx,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

XXX: I suspect that the ticket number may be the only thing here's that's actually important, since it could be used in proofs of double-spending (on the CP's behalf).

func (*TicketL1) CanonicalDigest 

func (m *TicketL1) CanonicalDigest() []byte

func (*TicketL1) Descriptor 

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

func (*TicketL1) GetCachePublicKey 

func (m *TicketL1) GetCachePublicKey() *PublicKey

func (*TicketL1) GetChunkIdx 

func (m *TicketL1) GetChunkIdx() uint64

func (*TicketL1) GetTicketNo 

func (m *TicketL1) GetTicketNo() uint64

func (*TicketL1) Marshal 

func (m *TicketL1) Marshal() (dAtA []byte, err error)

func (*TicketL1) MarshalTo 

func (m *TicketL1) MarshalTo(dAtA []byte) (int, error)

func (*TicketL1) ProtoMessage 

func (*TicketL1) ProtoMessage()

func (*TicketL1) Reset 

func (m *TicketL1) Reset()

func (*TicketL1) Size 

func (m *TicketL1) Size() (n int)

func (*TicketL1) String 

func (m *TicketL1) String() string

func (*TicketL1) Unmarshal 

func (m *TicketL1) Unmarshal(dAtA []byte) error

func (*TicketL1) XXX_DiscardUnknown 

func (m *TicketL1) XXX_DiscardUnknown()

func (*TicketL1) XXX_Marshal 

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

func (*TicketL1) XXX_Merge 

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

func (*TicketL1) XXX_Size 

func (m *TicketL1) XXX_Size() int

func (*TicketL1) XXX_Unmarshal 

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

type TicketL2 

type TicketL2 struct {
	// XXX: It seems like it might not be too hard for a cache to guess the plaintext L2 ticket that corresponds to the
	// hash that it knows.  This would be harder if we didn't tell each cache the other caches' public keys *and*
	// included all of those keys in the hashed ticket L2.  However, it still seems as though the group of hashes trying
	// to claim the ticket could find each other when they all show up to try to claim their win.
	Nonce []byte `protobuf:"bytes,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// The inner session keys are here in order to force the client to solve the colocation puzzle (which is required in
	// order to decrypt the L2 ticket).
	InnerSessionKey      []*BlockKey `protobuf:"bytes,3,rep,name=inner_session_key,json=innerSessionKey,proto3" json:"inner_session_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

By the time the L2 ticket is decrypted by the client, all of the caches must have provided data and outer encryption keys to the client; these are the inputs to the colocation puzzle, whose output is used to decrypt the L2 ticket.

func (*TicketL2) CanonicalDigest 

func (m *TicketL2) CanonicalDigest() []byte

func (*TicketL2) Descriptor 

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

func (*TicketL2) GetInnerSessionKey 

func (m *TicketL2) GetInnerSessionKey() []*BlockKey

func (*TicketL2) GetNonce 

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

func (*TicketL2) Marshal 

func (m *TicketL2) Marshal() (dAtA []byte, err error)

func (*TicketL2) MarshalTo 

func (m *TicketL2) MarshalTo(dAtA []byte) (int, error)

func (*TicketL2) ProtoMessage 

func (*TicketL2) ProtoMessage()

func (*TicketL2) Reset 

func (m *TicketL2) Reset()

func (*TicketL2) Size 

func (m *TicketL2) Size() (n int)

func (*TicketL2) String 

func (m *TicketL2) String() string

func (*TicketL2) Unmarshal 

func (m *TicketL2) Unmarshal(dAtA []byte) error

func (*TicketL2) XXX_DiscardUnknown 

func (m *TicketL2) XXX_DiscardUnknown()

func (*TicketL2) XXX_Marshal 

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

func (*TicketL2) XXX_Merge 

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

func (*TicketL2) XXX_Size 

func (m *TicketL2) XXX_Size() int

func (*TicketL2) XXX_Unmarshal 

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

type TicketL2Info 

type TicketL2Info struct {
	EncryptedTicketL2    []byte   `protobuf:"bytes,1,opt,name=encrypted_ticket_l2,json=encryptedTicketL2,proto3" json:"encrypted_ticket_l2,omitempty"`
	PuzzleSecret         []byte   `protobuf:"bytes,2,opt,name=puzzle_secret,json=puzzleSecret,proto3" json:"puzzle_secret,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TicketL2Info) Descriptor 

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

func (*TicketL2Info) EncryptedTicketL2Digest 

func (m *TicketL2Info) EncryptedTicketL2Digest() []byte

func (*TicketL2Info) GetEncryptedTicketL2 

func (m *TicketL2Info) GetEncryptedTicketL2() []byte

func (*TicketL2Info) GetPuzzleSecret 

func (m *TicketL2Info) GetPuzzleSecret() []byte

func (*TicketL2Info) Marshal 

func (m *TicketL2Info) Marshal() (dAtA []byte, err error)

func (*TicketL2Info) MarshalTo 

func (m *TicketL2Info) MarshalTo(dAtA []byte) (int, error)

func (*TicketL2Info) ProtoMessage 

func (*TicketL2Info) ProtoMessage()

func (*TicketL2Info) Reset 

func (m *TicketL2Info) Reset()

func (*TicketL2Info) Size 

func (m *TicketL2Info) Size() (n int)

func (*TicketL2Info) String 

func (m *TicketL2Info) String() string

func (*TicketL2Info) Unmarshal 

func (m *TicketL2Info) Unmarshal(dAtA []byte) error

func (*TicketL2Info) XXX_DiscardUnknown 

func (m *TicketL2Info) XXX_DiscardUnknown()

func (*TicketL2Info) XXX_Marshal 

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

func (*TicketL2Info) XXX_Merge 

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

func (*TicketL2Info) XXX_Size 

func (m *TicketL2Info) XXX_Size() int

func (*TicketL2Info) XXX_Unmarshal 

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

type TicketRequest 

type TicketRequest struct {
	ChunkIdx             uint64     `protobuf:"varint,2,opt,name=chunk_idx,json=chunkIdx,proto3" json:"chunk_idx,omitempty"`
	InnerKey             *BlockKey  `protobuf:"bytes,3,opt,name=inner_key,json=innerKey,proto3" json:"inner_key,omitempty"`
	ChunkId              []byte     `protobuf:"bytes,5,opt,name=chunk_id,json=chunkId,proto3" json:"chunk_id,omitempty"`
	CachePublicKey       *PublicKey `protobuf:"bytes,4,opt,name=cache_public_key,json=cachePublicKey,proto3" json:"cache_public_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

This is what the client will present to the cache. It's not individually signed, but it's covered by the batch signature.

func (*TicketRequest) CanonicalDigest 

func (m *TicketRequest) CanonicalDigest() []byte

func (*TicketRequest) Descriptor 

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

func (*TicketRequest) GetCachePublicKey 

func (m *TicketRequest) GetCachePublicKey() *PublicKey

func (*TicketRequest) GetChunkId 

func (m *TicketRequest) GetChunkId() []byte

func (*TicketRequest) GetChunkIdx 

func (m *TicketRequest) GetChunkIdx() uint64

func (*TicketRequest) GetInnerKey 

func (m *TicketRequest) GetInnerKey() *BlockKey

func (*TicketRequest) Marshal 

func (m *TicketRequest) Marshal() (dAtA []byte, err error)

func (*TicketRequest) MarshalTo 

func (m *TicketRequest) MarshalTo(dAtA []byte) (int, error)

func (*TicketRequest) ProtoMessage 

func (*TicketRequest) ProtoMessage()

func (*TicketRequest) Reset 

func (m *TicketRequest) Reset()

func (*TicketRequest) Size 

func (m *TicketRequest) Size() (n int)

func (*TicketRequest) String 

func (m *TicketRequest) String() string

func (*TicketRequest) Unmarshal 

func (m *TicketRequest) Unmarshal(dAtA []byte) error

func (*TicketRequest) XXX_DiscardUnknown 

func (m *TicketRequest) XXX_DiscardUnknown()

func (*TicketRequest) XXX_Marshal 

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

func (*TicketRequest) XXX_Merge 

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

func (*TicketRequest) XXX_Size 

func (m *TicketRequest) XXX_Size() int

func (*TicketRequest) XXX_Unmarshal 

func (m *TicketRequest) 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.