contentd

package
v0.0.0-...-9647411 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 2020 License: MIT Imports: 83 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthKeystore        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowKeystore          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupKeystore = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthResolver        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowResolver          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupResolver = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var KeyType_name = map[int32]string{
	0: "RSA",
	1: "Ed25519",
	2: "Secp256k1",
	3: "ECDSA",
}
View Source 
var KeyType_value = map[string]int32{
	"RSA":       0,
	"Ed25519":   1,
	"Secp256k1": 2,
	"ECDSA":     3,
}
View Source 
var (
	ReprovideInterval = 12 * time.Hour
)

Functions

func FromFetcher 

func FromFetcher(f remotes.Fetcher) content.Provider

func Libp2pCidFromPubKey 

func Libp2pCidFromPubKey(data []byte) (cid.Cid, error)

func NewBlockstore 

func NewBlockstore(ctx context.Context, ds datastore.Batching) (blockstore.Blockstore, error)

func NewProviderSystem 

func NewProviderSystem(ctx context.Context, ds datastore.Batching, bs blockstore.Blockstore, r routing.ContentRouting) (provider.System, error)

func RegisterKeystoreServer 

func RegisterKeystoreServer(s *grpc.Server, srv KeystoreServer)

func RegisterResolverServer 

func RegisterResolverServer(s *grpc.Server, srv ResolverServer)

Types

type AddRequest 

type AddRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	PublicKey            []byte   `protobuf:"bytes,2,opt,name=publicKey,proto3" json:"publicKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddRequest) Descriptor 

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

func (*AddRequest) Marshal 

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

func (*AddRequest) MarshalTo 

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

func (*AddRequest) MarshalToSizedBuffer 

func (m *AddRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddRequest) ProtoMessage 

func (*AddRequest) ProtoMessage()

func (*AddRequest) Reset 

func (m *AddRequest) Reset()

func (*AddRequest) Size 

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

func (*AddRequest) String 

func (this *AddRequest) String() string

func (*AddRequest) Unmarshal 

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

func (*AddRequest) XXX_DiscardUnknown 

func (m *AddRequest) XXX_DiscardUnknown()

func (*AddRequest) XXX_Marshal 

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

func (*AddRequest) XXX_Merge 

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

func (*AddRequest) XXX_Size 

func (m *AddRequest) XXX_Size() int

func (*AddRequest) XXX_Unmarshal 

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

type AddResponse 

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

func (*AddResponse) Descriptor 

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

func (*AddResponse) Marshal 

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

func (*AddResponse) MarshalTo 

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

func (*AddResponse) MarshalToSizedBuffer 

func (m *AddResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddResponse) ProtoMessage 

func (*AddResponse) ProtoMessage()

func (*AddResponse) Reset 

func (m *AddResponse) Reset()

func (*AddResponse) Size 

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

func (*AddResponse) String 

func (this *AddResponse) String() string

func (*AddResponse) Unmarshal 

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

func (*AddResponse) XXX_DiscardUnknown 

func (m *AddResponse) XXX_DiscardUnknown()

func (*AddResponse) XXX_Marshal 

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

func (*AddResponse) XXX_Merge 

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

func (*AddResponse) XXX_Size 

func (m *AddResponse) XXX_Size() int

func (*AddResponse) XXX_Unmarshal 

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

type Client 

type Client struct {
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(address string) (*Client, error)

func (*Client) Keystore 

func (c *Client) Keystore() Keystore

func (*Client) Reconnect 

func (c *Client) Reconnect() error

Reconnect re-establishes the GRPC connection to the contentd daemon

func (*Client) Resolver 

func (c *Client) Resolver() remotes.Resolver

type Converter 

type Converter interface {
	Convert(ctx context.Context, desc ocispec.Descriptor) (ocispec.Descriptor, error)
}

Converter converts OCI images to p2p distributed images via IPFS.

func NewConverter 

func NewConverter(store content.Store, provider content.Provider) Converter

NewConverter returns a new image manifest converter.

type GenerateRequest 

type GenerateRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type                 KeyType  `protobuf:"varint,2,opt,name=type,proto3,enum=contentd.services.keystore.v1.KeyType" json:"type,omitempty"`
	Size_                uint32   `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GenerateRequest) Descriptor 

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

func (*GenerateRequest) Marshal 

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

func (*GenerateRequest) MarshalTo 

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

func (*GenerateRequest) MarshalToSizedBuffer 

func (m *GenerateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenerateRequest) ProtoMessage 

func (*GenerateRequest) ProtoMessage()

func (*GenerateRequest) Reset 

func (m *GenerateRequest) Reset()

func (*GenerateRequest) Size 

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

func (*GenerateRequest) String 

func (this *GenerateRequest) String() string

func (*GenerateRequest) Unmarshal 

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

func (*GenerateRequest) XXX_DiscardUnknown 

func (m *GenerateRequest) XXX_DiscardUnknown()

func (*GenerateRequest) XXX_Marshal 

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

func (*GenerateRequest) XXX_Merge 

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

func (*GenerateRequest) XXX_Size 

func (m *GenerateRequest) XXX_Size() int

func (*GenerateRequest) XXX_Unmarshal 

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

type GenerateResponse 

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

func (*GenerateResponse) Descriptor 

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

func (*GenerateResponse) Marshal 

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

func (*GenerateResponse) MarshalTo 

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

func (*GenerateResponse) MarshalToSizedBuffer 

func (m *GenerateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenerateResponse) ProtoMessage 

func (*GenerateResponse) ProtoMessage()

func (*GenerateResponse) Reset 

func (m *GenerateResponse) Reset()

func (*GenerateResponse) Size 

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

func (*GenerateResponse) String 

func (this *GenerateResponse) String() string

func (*GenerateResponse) Unmarshal 

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

func (*GenerateResponse) XXX_DiscardUnknown 

func (m *GenerateResponse) XXX_DiscardUnknown()

func (*GenerateResponse) XXX_Marshal 

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

func (*GenerateResponse) XXX_Merge 

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

func (*GenerateResponse) XXX_Size 

func (m *GenerateResponse) XXX_Size() int

func (*GenerateResponse) XXX_Unmarshal 

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

type Key 

type Key struct {
	Name                 string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	PublicKey            PublicKey `protobuf:"bytes,2,opt,name=publicKey,proto3" json:"publicKey"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Key) Descriptor 

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

func (*Key) Marshal 

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

func (*Key) MarshalTo 

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

func (*Key) MarshalToSizedBuffer 

func (m *Key) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Key) ProtoMessage 

func (*Key) ProtoMessage()

func (*Key) Reset 

func (m *Key) Reset()

func (*Key) Size 

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

func (*Key) String 

func (this *Key) String() string

func (*Key) Unmarshal 

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

func (*Key) XXX_DiscardUnknown 

func (m *Key) XXX_DiscardUnknown()

func (*Key) XXX_Marshal 

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

func (*Key) XXX_Merge 

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

func (*Key) XXX_Size 

func (m *Key) XXX_Size() int

func (*Key) XXX_Unmarshal 

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

type KeyType 

type KeyType int32
const (
	KeyType_RSA       KeyType = 0
	KeyType_Ed25519   KeyType = 1
	KeyType_Secp256k1 KeyType = 2
	KeyType_ECDSA     KeyType = 3
)

func (KeyType) EnumDescriptor 

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

func (KeyType) String 

func (x KeyType) String() string

type Keystore 

type Keystore interface {
	Add(ctx context.Context, name, pubKey string) error
	Generate(ctx context.Context, name, keyType string, size int) (key Key, err error)
	List(ctx context.Context) ([]*Key, error)
	Remove(ctx context.Context, names ...string) ([]string, error)
	Rename(ctx context.Context, oldName, newName string) error
}

type KeystoreClient 

type KeystoreClient interface {
	Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error)
	Generate(ctx context.Context, in *GenerateRequest, opts ...grpc.CallOption) (*GenerateResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error)
	Rename(ctx context.Context, in *RenameRequest, opts ...grpc.CallOption) (*RenameResponse, error)
}

KeystoreClient is the client API for Keystore service.

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

func NewKeystoreClient 

func NewKeystoreClient(cc *grpc.ClientConn) KeystoreClient

type KeystoreServer 

type KeystoreServer interface {
	Add(context.Context, *AddRequest) (*AddResponse, error)
	Generate(context.Context, *GenerateRequest) (*GenerateResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
	Rename(context.Context, *RenameRequest) (*RenameResponse, error)
}

KeystoreServer is the server API for Keystore service.

type ListRequest 

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

func (*ListRequest) Descriptor 

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

func (*ListRequest) Marshal 

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

func (*ListRequest) MarshalTo 

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

func (*ListRequest) MarshalToSizedBuffer 

func (m *ListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset 

func (m *ListRequest) Reset()

func (*ListRequest) Size 

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

func (*ListRequest) String 

func (this *ListRequest) String() string

func (*ListRequest) Unmarshal 

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

func (*ListRequest) XXX_DiscardUnknown 

func (m *ListRequest) XXX_DiscardUnknown()

func (*ListRequest) XXX_Marshal 

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

func (*ListRequest) XXX_Merge 

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

func (*ListRequest) XXX_Size 

func (m *ListRequest) XXX_Size() int

func (*ListRequest) XXX_Unmarshal 

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

type ListResponse 

type ListResponse struct {
	Keys                 []*Key   `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListResponse) Descriptor 

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

func (*ListResponse) Marshal 

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

func (*ListResponse) MarshalTo 

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

func (*ListResponse) MarshalToSizedBuffer 

func (m *ListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) Reset 

func (m *ListResponse) Reset()

func (*ListResponse) Size 

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

func (*ListResponse) String 

func (this *ListResponse) String() string

func (*ListResponse) Unmarshal 

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

func (*ListResponse) XXX_DiscardUnknown 

func (m *ListResponse) XXX_DiscardUnknown()

func (*ListResponse) XXX_Marshal 

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

func (*ListResponse) XXX_Merge 

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

func (*ListResponse) XXX_Size 

func (m *ListResponse) XXX_Size() int

func (*ListResponse) XXX_Unmarshal 

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

type Peer 

type Peer struct {
	// contains filtered or unexported fields
}

func New 

func New(ctx context.Context, addr, root string) (*Peer, error)

func (*Peer) Abort 

func (p *Peer) Abort(ctx context.Context, ref string) error

Abort completely cancels the ingest operation targeted by ref.

func (*Peer) Add 

func (p *Peer) Add(ctx context.Context, r io.Reader) (ipld.Node, error)

func (*Peer) DAGService 

func (p *Peer) DAGService() ipld.DAGService

func (*Peer) Delete 

func (p *Peer) Delete(ctx context.Context, dgst digest.Digest) error

Delete removes the content from the store.

func (*Peer) Get 

func (p *Peer) Get(ctx context.Context, ref string) (ipld.Node, error)

func (*Peer) GetFile 

func (p *Peer) GetFile(ctx context.Context, ref string) (files.File, error)

func (*Peer) Host 

func (p *Peer) Host() host.Host

func (*Peer) Info 

func (p *Peer) Info(ctx context.Context, dgst digest.Digest) (content.Info, error)

Info will return metadata about content available in the content store.

If the content is not present, ErrNotFound will be returned.

func (*Peer) Keystore 

func (p *Peer) Keystore() KeystoreServer

func (*Peer) ListStatuses 

func (p *Peer) ListStatuses(ctx context.Context, filters ...string) ([]content.Status, error)

ListStatuses returns the status of any active ingestions whose ref match the provided regular expression. If empty, all active ingestions will be returned.

func (*Peer) ReaderAt 

func (p *Peer) ReaderAt(ctx context.Context, desc ocispec.Descriptor) (content.ReaderAt, error)

ReaderAt only requires desc.Digest to be set. Other fields in the descriptor may be used internally for resolving the location of the actual data.

func (*Peer) Resolve 

func (p *Peer) Resolve(ctx context.Context, req *ResolveRequest) (*ResolveResponse, error)

func (*Peer) Status 

func (p *Peer) Status(ctx context.Context, ref string) (content.Status, error)

Status returns the status of the provided ref.

func (*Peer) Update 

func (p *Peer) Update(ctx context.Context, info content.Info, fieldpaths ...string) (content.Info, error)

Update updates mutable information related to content. If one or more fieldpaths are provided, only those fields will be updated. Mutable fields: 

labels.*

func (*Peer) Walk 

func (p *Peer) Walk(ctx context.Context, fn content.WalkFunc, filters ...string) error

Walk will call fn for each item in the content store which match the provided filters. If no filters are given all items will be walked.

func (*Peer) Writer 

func (p *Peer) Writer(ctx context.Context, opts ...content.WriterOpt) (content.Writer, error)

type PublicKey 

type PublicKey struct {
	Type                 KeyType  `protobuf:"varint,1,opt,name=type,proto3,enum=contentd.services.keystore.v1.KeyType" json:"type,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PublicKey) Descriptor 

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

func (*PublicKey) Marshal 

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

func (*PublicKey) MarshalTo 

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

func (*PublicKey) MarshalToSizedBuffer 

func (m *PublicKey) MarshalToSizedBuffer(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 (this *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 RemoveRequest 

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

func (*RemoveRequest) Descriptor 

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

func (*RemoveRequest) Marshal 

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

func (*RemoveRequest) MarshalTo 

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

func (*RemoveRequest) MarshalToSizedBuffer 

func (m *RemoveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) Reset 

func (m *RemoveRequest) Reset()

func (*RemoveRequest) Size 

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

func (*RemoveRequest) String 

func (this *RemoveRequest) String() string

func (*RemoveRequest) Unmarshal 

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

func (*RemoveRequest) XXX_DiscardUnknown 

func (m *RemoveRequest) XXX_DiscardUnknown()

func (*RemoveRequest) XXX_Marshal 

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

func (*RemoveRequest) XXX_Merge 

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

func (*RemoveRequest) XXX_Size 

func (m *RemoveRequest) XXX_Size() int

func (*RemoveRequest) XXX_Unmarshal 

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

type RemoveResponse 

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

func (*RemoveResponse) Descriptor 

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

func (*RemoveResponse) Marshal 

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

func (*RemoveResponse) MarshalTo 

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

func (*RemoveResponse) MarshalToSizedBuffer 

func (m *RemoveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoveResponse) ProtoMessage 

func (*RemoveResponse) ProtoMessage()

func (*RemoveResponse) Reset 

func (m *RemoveResponse) Reset()

func (*RemoveResponse) Size 

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

func (*RemoveResponse) String 

func (this *RemoveResponse) String() string

func (*RemoveResponse) Unmarshal 

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

func (*RemoveResponse) XXX_DiscardUnknown 

func (m *RemoveResponse) XXX_DiscardUnknown()

func (*RemoveResponse) XXX_Marshal 

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

func (*RemoveResponse) XXX_Merge 

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

func (*RemoveResponse) XXX_Size 

func (m *RemoveResponse) XXX_Size() int

func (*RemoveResponse) XXX_Unmarshal 

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

type RenameRequest 

type RenameRequest struct {
	OldName              string   `protobuf:"bytes,1,opt,name=oldName,proto3" json:"oldName,omitempty"`
	NewName              string   `protobuf:"bytes,2,opt,name=newName,proto3" json:"newName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RenameRequest) Descriptor 

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

func (*RenameRequest) Marshal 

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

func (*RenameRequest) MarshalTo 

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

func (*RenameRequest) MarshalToSizedBuffer 

func (m *RenameRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RenameRequest) ProtoMessage 

func (*RenameRequest) ProtoMessage()

func (*RenameRequest) Reset 

func (m *RenameRequest) Reset()

func (*RenameRequest) Size 

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

func (*RenameRequest) String 

func (this *RenameRequest) String() string

func (*RenameRequest) Unmarshal 

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

func (*RenameRequest) XXX_DiscardUnknown 

func (m *RenameRequest) XXX_DiscardUnknown()

func (*RenameRequest) XXX_Marshal 

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

func (*RenameRequest) XXX_Merge 

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

func (*RenameRequest) XXX_Size 

func (m *RenameRequest) XXX_Size() int

func (*RenameRequest) XXX_Unmarshal 

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

type RenameResponse 

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

func (*RenameResponse) Descriptor 

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

func (*RenameResponse) Marshal 

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

func (*RenameResponse) MarshalTo 

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

func (*RenameResponse) MarshalToSizedBuffer 

func (m *RenameResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RenameResponse) ProtoMessage 

func (*RenameResponse) ProtoMessage()

func (*RenameResponse) Reset 

func (m *RenameResponse) Reset()

func (*RenameResponse) Size 

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

func (*RenameResponse) String 

func (this *RenameResponse) String() string

func (*RenameResponse) Unmarshal 

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

func (*RenameResponse) XXX_DiscardUnknown 

func (m *RenameResponse) XXX_DiscardUnknown()

func (*RenameResponse) XXX_Marshal 

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

func (*RenameResponse) XXX_Merge 

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

func (*RenameResponse) XXX_Size 

func (m *RenameResponse) XXX_Size() int

func (*RenameResponse) XXX_Unmarshal 

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

type ResolveRequest 

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

func (*ResolveRequest) Descriptor 

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

func (*ResolveRequest) Marshal 

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

func (*ResolveRequest) MarshalTo 

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

func (*ResolveRequest) MarshalToSizedBuffer 

func (m *ResolveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResolveRequest) ProtoMessage 

func (*ResolveRequest) ProtoMessage()

func (*ResolveRequest) Reset 

func (m *ResolveRequest) Reset()

func (*ResolveRequest) Size 

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

func (*ResolveRequest) String 

func (this *ResolveRequest) String() string

func (*ResolveRequest) Unmarshal 

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

func (*ResolveRequest) XXX_DiscardUnknown 

func (m *ResolveRequest) XXX_DiscardUnknown()

func (*ResolveRequest) XXX_Marshal 

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

func (*ResolveRequest) XXX_Merge 

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

func (*ResolveRequest) XXX_Size 

func (m *ResolveRequest) XXX_Size() int

func (*ResolveRequest) XXX_Unmarshal 

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

type ResolveResponse 

type ResolveResponse struct {
	Resolved             Resolved `protobuf:"bytes,1,opt,name=resolved,proto3" json:"resolved"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResolveResponse) Descriptor 

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

func (*ResolveResponse) Marshal 

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

func (*ResolveResponse) MarshalTo 

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

func (*ResolveResponse) MarshalToSizedBuffer 

func (m *ResolveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResolveResponse) ProtoMessage 

func (*ResolveResponse) ProtoMessage()

func (*ResolveResponse) Reset 

func (m *ResolveResponse) Reset()

func (*ResolveResponse) Size 

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

func (*ResolveResponse) String 

func (this *ResolveResponse) String() string

func (*ResolveResponse) Unmarshal 

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

func (*ResolveResponse) XXX_DiscardUnknown 

func (m *ResolveResponse) XXX_DiscardUnknown()

func (*ResolveResponse) XXX_Marshal 

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

func (*ResolveResponse) XXX_Merge 

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

func (*ResolveResponse) XXX_Size 

func (m *ResolveResponse) XXX_Size() int

func (*ResolveResponse) XXX_Unmarshal 

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

type Resolved 

type Resolved struct {
	Name                 string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Target               types.Descriptor `protobuf:"bytes,2,opt,name=target,proto3" json:"target"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Resolved) Descriptor 

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

func (*Resolved) Marshal 

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

func (*Resolved) MarshalTo 

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

func (*Resolved) MarshalToSizedBuffer 

func (m *Resolved) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Resolved) ProtoMessage 

func (*Resolved) ProtoMessage()

func (*Resolved) Reset 

func (m *Resolved) Reset()

func (*Resolved) Size 

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

func (*Resolved) String 

func (this *Resolved) String() string

func (*Resolved) Unmarshal 

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

func (*Resolved) XXX_DiscardUnknown 

func (m *Resolved) XXX_DiscardUnknown()

func (*Resolved) XXX_Marshal 

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

func (*Resolved) XXX_Merge 

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

func (*Resolved) XXX_Size 

func (m *Resolved) XXX_Size() int

func (*Resolved) XXX_Unmarshal 

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

type ResolverClient 

type ResolverClient interface {
	Resolve(ctx context.Context, in *ResolveRequest, opts ...grpc.CallOption) (*ResolveResponse, error)
}

ResolverClient is the client API for Resolver service.

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

func NewResolverClient 

func NewResolverClient(cc *grpc.ClientConn) ResolverClient

type ResolverServer 

type ResolverServer interface {
	Resolve(context.Context, *ResolveRequest) (*ResolveResponse, error)
}

ResolverServer is the server API for Resolver service.

type UnimplementedKeystoreServer 

type UnimplementedKeystoreServer struct {
}

UnimplementedKeystoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedKeystoreServer) Add 

func (*UnimplementedKeystoreServer) Add(ctx context.Context, req *AddRequest) (*AddResponse, error)

func (*UnimplementedKeystoreServer) Generate 

func (*UnimplementedKeystoreServer) Generate(ctx context.Context, req *GenerateRequest) (*GenerateResponse, error)

func (*UnimplementedKeystoreServer) List 

func (*UnimplementedKeystoreServer) List(ctx context.Context, req *ListRequest) (*ListResponse, error)

func (*UnimplementedKeystoreServer) Remove 

func (*UnimplementedKeystoreServer) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error)

func (*UnimplementedKeystoreServer) Rename 

func (*UnimplementedKeystoreServer) Rename(ctx context.Context, req *RenameRequest) (*RenameResponse, error)

type UnimplementedResolverServer 

type UnimplementedResolverServer struct {
}

UnimplementedResolverServer can be embedded to have forward compatible implementations.

func (*UnimplementedResolverServer) Resolve 

func (*UnimplementedResolverServer) Resolve(ctx context.Context, req *ResolveRequest) (*ResolveResponse, 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.