filecoin_deals_pb

package
v0.0.0-...-be0f657 Latest Latest
Warning

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

 Go to latest Published: Feb 3, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterAPIServer 

func RegisterAPIServer(s *grpc.Server, srv APIServer)

Types

type APIClient 

type APIClient interface {
	Store(ctx context.Context, opts ...grpc.CallOption) (API_StoreClient, error)
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (API_WatchClient, error)
}

APIClient is the client API for API service.

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

func NewAPIClient 

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer 

type APIServer interface {
	Store(API_StoreServer) error
	Watch(*WatchRequest, API_WatchServer) error
}

APIServer is the server API for API service.

type API_StoreClient 

type API_StoreClient interface {
	Send(*StoreRequest) error
	CloseAndRecv() (*StoreReply, error)
	grpc.ClientStream
}

type API_StoreServer 

type API_StoreServer interface {
	SendAndClose(*StoreReply) error
	Recv() (*StoreRequest, error)
	grpc.ServerStream
}

type API_WatchClient 

type API_WatchClient interface {
	Recv() (*WatchReply, error)
	grpc.ClientStream
}

type API_WatchServer 

type API_WatchServer interface {
	Send(*WatchReply) error
	grpc.ServerStream
}

type DealConfig 

type DealConfig struct {
	Miner                string   `protobuf:"bytes,1,opt,name=miner,proto3" json:"miner,omitempty"`
	EpochPrice           uint64   `protobuf:"varint,2,opt,name=epochPrice,proto3" json:"epochPrice,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DealConfig) Descriptor 

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

func (*DealConfig) GetEpochPrice 

func (m *DealConfig) GetEpochPrice() uint64

func (*DealConfig) GetMiner 

func (m *DealConfig) GetMiner() string

func (*DealConfig) ProtoMessage 

func (*DealConfig) ProtoMessage()

func (*DealConfig) Reset 

func (m *DealConfig) Reset()

func (*DealConfig) String 

func (m *DealConfig) String() string

func (*DealConfig) XXX_DiscardUnknown 

func (m *DealConfig) XXX_DiscardUnknown()

func (*DealConfig) XXX_Marshal 

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

func (*DealConfig) XXX_Merge 

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

func (*DealConfig) XXX_Size 

func (m *DealConfig) XXX_Size() int

func (*DealConfig) XXX_Unmarshal 

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

type DealInfo 

type DealInfo struct {
	ProposalCid          string   `protobuf:"bytes,1,opt,name=proposalCid,proto3" json:"proposalCid,omitempty"`
	StateID              uint64   `protobuf:"varint,2,opt,name=stateID,proto3" json:"stateID,omitempty"`
	StateName            string   `protobuf:"bytes,3,opt,name=stateName,proto3" json:"stateName,omitempty"`
	Miner                string   `protobuf:"bytes,4,opt,name=miner,proto3" json:"miner,omitempty"`
	PieceRef             []byte   `protobuf:"bytes,5,opt,name=pieceRef,proto3" json:"pieceRef,omitempty"`
	Size                 uint64   `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"`
	PricePerEpoch        uint64   `protobuf:"varint,7,opt,name=pricePerEpoch,proto3" json:"pricePerEpoch,omitempty"`
	Duration             uint64   `protobuf:"varint,8,opt,name=duration,proto3" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DealInfo) Descriptor 

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

func (*DealInfo) GetDuration 

func (m *DealInfo) GetDuration() uint64

func (*DealInfo) GetMiner 

func (m *DealInfo) GetMiner() string

func (*DealInfo) GetPieceRef 

func (m *DealInfo) GetPieceRef() []byte

func (*DealInfo) GetPricePerEpoch 

func (m *DealInfo) GetPricePerEpoch() uint64

func (*DealInfo) GetProposalCid 

func (m *DealInfo) GetProposalCid() string

func (*DealInfo) GetSize 

func (m *DealInfo) GetSize() uint64

func (*DealInfo) GetStateID 

func (m *DealInfo) GetStateID() uint64

func (*DealInfo) GetStateName 

func (m *DealInfo) GetStateName() string

func (*DealInfo) ProtoMessage 

func (*DealInfo) ProtoMessage()

func (*DealInfo) Reset 

func (m *DealInfo) Reset()

func (*DealInfo) String 

func (m *DealInfo) String() string

func (*DealInfo) XXX_DiscardUnknown 

func (m *DealInfo) XXX_DiscardUnknown()

func (*DealInfo) XXX_Marshal 

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

func (*DealInfo) XXX_Merge 

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

func (*DealInfo) XXX_Size 

func (m *DealInfo) XXX_Size() int

func (*DealInfo) XXX_Unmarshal 

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

type StoreParams 

type StoreParams struct {
	Address              string        `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	DealConfigs          []*DealConfig `protobuf:"bytes,2,rep,name=dealConfigs,proto3" json:"dealConfigs,omitempty"`
	Duration             uint64        `protobuf:"varint,3,opt,name=duration,proto3" json:"duration,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*StoreParams) Descriptor 

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

func (*StoreParams) GetAddress 

func (m *StoreParams) GetAddress() string

func (*StoreParams) GetDealConfigs 

func (m *StoreParams) GetDealConfigs() []*DealConfig

func (*StoreParams) GetDuration 

func (m *StoreParams) GetDuration() uint64

func (*StoreParams) ProtoMessage 

func (*StoreParams) ProtoMessage()

func (*StoreParams) Reset 

func (m *StoreParams) Reset()

func (*StoreParams) String 

func (m *StoreParams) String() string

func (*StoreParams) XXX_DiscardUnknown 

func (m *StoreParams) XXX_DiscardUnknown()

func (*StoreParams) XXX_Marshal 

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

func (*StoreParams) XXX_Merge 

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

func (*StoreParams) XXX_Size 

func (m *StoreParams) XXX_Size() int

func (*StoreParams) XXX_Unmarshal 

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

type StoreReply 

type StoreReply struct {
	Cids                 []string      `protobuf:"bytes,1,rep,name=cids,proto3" json:"cids,omitempty"`
	FailedDeals          []*DealConfig `protobuf:"bytes,2,rep,name=failedDeals,proto3" json:"failedDeals,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*StoreReply) Descriptor 

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

func (*StoreReply) GetCids 

func (m *StoreReply) GetCids() []string

func (*StoreReply) GetFailedDeals 

func (m *StoreReply) GetFailedDeals() []*DealConfig

func (*StoreReply) ProtoMessage 

func (*StoreReply) ProtoMessage()

func (*StoreReply) Reset 

func (m *StoreReply) Reset()

func (*StoreReply) String 

func (m *StoreReply) String() string

func (*StoreReply) XXX_DiscardUnknown 

func (m *StoreReply) XXX_DiscardUnknown()

func (*StoreReply) XXX_Marshal 

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

func (*StoreReply) XXX_Merge 

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

func (*StoreReply) XXX_Size 

func (m *StoreReply) XXX_Size() int

func (*StoreReply) XXX_Unmarshal 

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

type StoreRequest 

type StoreRequest struct {
	// Types that are valid to be assigned to Payload:
	//	*StoreRequest_StoreParams
	//	*StoreRequest_Chunk
	Payload              isStoreRequest_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*StoreRequest) Descriptor 

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

func (*StoreRequest) GetChunk 

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

func (*StoreRequest) GetPayload 

func (m *StoreRequest) GetPayload() isStoreRequest_Payload

func (*StoreRequest) GetStoreParams 

func (m *StoreRequest) GetStoreParams() *StoreParams

func (*StoreRequest) ProtoMessage 

func (*StoreRequest) ProtoMessage()

func (*StoreRequest) Reset 

func (m *StoreRequest) Reset()

func (*StoreRequest) String 

func (m *StoreRequest) String() string

func (*StoreRequest) XXX_DiscardUnknown 

func (m *StoreRequest) XXX_DiscardUnknown()

func (*StoreRequest) XXX_Marshal 

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

func (*StoreRequest) XXX_Merge 

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

func (*StoreRequest) XXX_OneofWrappers 

func (*StoreRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StoreRequest) XXX_Size 

func (m *StoreRequest) XXX_Size() int

func (*StoreRequest) XXX_Unmarshal 

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

type StoreRequest_Chunk 

type StoreRequest_Chunk struct {
	Chunk []byte `protobuf:"bytes,2,opt,name=chunk,proto3,oneof"`
}

type StoreRequest_StoreParams 

type StoreRequest_StoreParams struct {
	StoreParams *StoreParams `protobuf:"bytes,1,opt,name=storeParams,proto3,oneof"`
}

type UnimplementedAPIServer 

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPIServer) Store 

func (*UnimplementedAPIServer) Store(srv API_StoreServer) error

func (*UnimplementedAPIServer) Watch 

func (*UnimplementedAPIServer) Watch(req *WatchRequest, srv API_WatchServer) error

type WatchReply 

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

func (*WatchReply) Descriptor 

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

func (*WatchReply) GetDealInfo 

func (m *WatchReply) GetDealInfo() *DealInfo

func (*WatchReply) ProtoMessage 

func (*WatchReply) ProtoMessage()

func (*WatchReply) Reset 

func (m *WatchReply) Reset()

func (*WatchReply) String 

func (m *WatchReply) String() string

func (*WatchReply) XXX_DiscardUnknown 

func (m *WatchReply) XXX_DiscardUnknown()

func (*WatchReply) XXX_Marshal 

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

func (*WatchReply) XXX_Merge 

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

func (*WatchReply) XXX_Size 

func (m *WatchReply) XXX_Size() int

func (*WatchReply) XXX_Unmarshal 

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

type WatchRequest 

type WatchRequest struct {
	Proposals            []string `protobuf:"bytes,1,rep,name=proposals,proto3" json:"proposals,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatchRequest) Descriptor 

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

func (*WatchRequest) GetProposals 

func (m *WatchRequest) GetProposals() []string

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) Reset 

func (m *WatchRequest) Reset()

func (*WatchRequest) String 

func (m *WatchRequest) String() string

func (*WatchRequest) XXX_DiscardUnknown 

func (m *WatchRequest) XXX_DiscardUnknown()

func (*WatchRequest) XXX_Marshal 

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

func (*WatchRequest) XXX_Merge 

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

func (*WatchRequest) XXX_Size 

func (m *WatchRequest) XXX_Size() int

func (*WatchRequest) XXX_Unmarshal 

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