go_micro_srv_blob

package
v0.0.0-...-2baf605 Latest Latest
Warning

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

 Go to latest Published: Aug 9, 2019 License: Apache-2.0 Imports: 6 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterBlobHandler 

func RegisterBlobHandler(s server.Server, hdlr BlobHandler, opts ...server.HandlerOption) error

Types

type BlobHandler 

type BlobHandler interface {
	CreateBucket(context.Context, *CreateBucketReq, *CreateBucketResp) error
	DeleteBucket(context.Context, *DeleteBucketReq, *DeleteBucketResp) error
	Put(context.Context, Blob_PutStream) error
	Get(context.Context, *GetReq, Blob_GetStream) error
	Delete(context.Context, *DeleteReq, *DeleteResp) error
	List(context.Context, *ListReq, *ListResp) error
}

type BlobService 

type BlobService interface {
	CreateBucket(ctx context.Context, in *CreateBucketReq, opts ...client.CallOption) (*CreateBucketResp, error)
	DeleteBucket(ctx context.Context, in *DeleteBucketReq, opts ...client.CallOption) (*DeleteBucketResp, error)
	Put(ctx context.Context, opts ...client.CallOption) (Blob_PutService, error)
	Get(ctx context.Context, in *GetReq, opts ...client.CallOption) (Blob_GetService, error)
	Delete(ctx context.Context, in *DeleteReq, opts ...client.CallOption) (*DeleteResp, error)
	List(ctx context.Context, in *ListReq, opts ...client.CallOption) (*ListResp, error)
}

func NewBlobService 

func NewBlobService(name string, c client.Client) BlobService

type Blob_GetService 

type Blob_GetService interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*GetResp, error)
}

type Blob_GetStream 

type Blob_GetStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*GetResp) error
}

type Blob_PutService 

type Blob_PutService interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*PutReq) error
}

type Blob_PutStream 

type Blob_PutStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*PutReq, error)
}

type CreateBucketReq 

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

func (*CreateBucketReq) Descriptor 

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

func (*CreateBucketReq) GetId 

func (m *CreateBucketReq) GetId() string

func (*CreateBucketReq) ProtoMessage 

func (*CreateBucketReq) ProtoMessage()

func (*CreateBucketReq) Reset 

func (m *CreateBucketReq) Reset()

func (*CreateBucketReq) String 

func (m *CreateBucketReq) String() string

func (*CreateBucketReq) XXX_DiscardUnknown 

func (m *CreateBucketReq) XXX_DiscardUnknown()

func (*CreateBucketReq) XXX_Marshal 

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

func (*CreateBucketReq) XXX_Merge 

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

func (*CreateBucketReq) XXX_Size 

func (m *CreateBucketReq) XXX_Size() int

func (*CreateBucketReq) XXX_Unmarshal 

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

type CreateBucketResp 

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

func (*CreateBucketResp) Descriptor 

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

func (*CreateBucketResp) ProtoMessage 

func (*CreateBucketResp) ProtoMessage()

func (*CreateBucketResp) Reset 

func (m *CreateBucketResp) Reset()

func (*CreateBucketResp) String 

func (m *CreateBucketResp) String() string

func (*CreateBucketResp) XXX_DiscardUnknown 

func (m *CreateBucketResp) XXX_DiscardUnknown()

func (*CreateBucketResp) XXX_Marshal 

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

func (*CreateBucketResp) XXX_Merge 

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

func (*CreateBucketResp) XXX_Size 

func (m *CreateBucketResp) XXX_Size() int

func (*CreateBucketResp) XXX_Unmarshal 

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

type DeleteBucketReq 

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

func (*DeleteBucketReq) Descriptor 

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

func (*DeleteBucketReq) GetId 

func (m *DeleteBucketReq) GetId() string

func (*DeleteBucketReq) ProtoMessage 

func (*DeleteBucketReq) ProtoMessage()

func (*DeleteBucketReq) Reset 

func (m *DeleteBucketReq) Reset()

func (*DeleteBucketReq) String 

func (m *DeleteBucketReq) String() string

func (*DeleteBucketReq) XXX_DiscardUnknown 

func (m *DeleteBucketReq) XXX_DiscardUnknown()

func (*DeleteBucketReq) XXX_Marshal 

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

func (*DeleteBucketReq) XXX_Merge 

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

func (*DeleteBucketReq) XXX_Size 

func (m *DeleteBucketReq) XXX_Size() int

func (*DeleteBucketReq) XXX_Unmarshal 

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

type DeleteBucketResp 

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

func (*DeleteBucketResp) Descriptor 

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

func (*DeleteBucketResp) ProtoMessage 

func (*DeleteBucketResp) ProtoMessage()

func (*DeleteBucketResp) Reset 

func (m *DeleteBucketResp) Reset()

func (*DeleteBucketResp) String 

func (m *DeleteBucketResp) String() string

func (*DeleteBucketResp) XXX_DiscardUnknown 

func (m *DeleteBucketResp) XXX_DiscardUnknown()

func (*DeleteBucketResp) XXX_Marshal 

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

func (*DeleteBucketResp) XXX_Merge 

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

func (*DeleteBucketResp) XXX_Size 

func (m *DeleteBucketResp) XXX_Size() int

func (*DeleteBucketResp) XXX_Unmarshal 

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

type DeleteReq 

type DeleteReq struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	BucketId             string   `protobuf:"bytes,2,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteReq) Descriptor 

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

func (*DeleteReq) GetBucketId 

func (m *DeleteReq) GetBucketId() string

func (*DeleteReq) GetId 

func (m *DeleteReq) GetId() string

func (*DeleteReq) ProtoMessage 

func (*DeleteReq) ProtoMessage()

func (*DeleteReq) Reset 

func (m *DeleteReq) Reset()

func (*DeleteReq) String 

func (m *DeleteReq) String() string

func (*DeleteReq) XXX_DiscardUnknown 

func (m *DeleteReq) XXX_DiscardUnknown()

func (*DeleteReq) XXX_Marshal 

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

func (*DeleteReq) XXX_Merge 

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

func (*DeleteReq) XXX_Size 

func (m *DeleteReq) XXX_Size() int

func (*DeleteReq) XXX_Unmarshal 

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

type DeleteResp 

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

func (*DeleteResp) Descriptor 

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

func (*DeleteResp) ProtoMessage 

func (*DeleteResp) ProtoMessage()

func (*DeleteResp) Reset 

func (m *DeleteResp) Reset()

func (*DeleteResp) String 

func (m *DeleteResp) String() string

func (*DeleteResp) XXX_DiscardUnknown 

func (m *DeleteResp) XXX_DiscardUnknown()

func (*DeleteResp) XXX_Marshal 

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

func (*DeleteResp) XXX_Merge 

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

func (*DeleteResp) XXX_Size 

func (m *DeleteResp) XXX_Size() int

func (*DeleteResp) XXX_Unmarshal 

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

type GetReq 

type GetReq struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	BucketId             string   `protobuf:"bytes,2,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetReq) Descriptor 

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

func (*GetReq) GetBucketId 

func (m *GetReq) GetBucketId() string

func (*GetReq) GetId 

func (m *GetReq) GetId() string

func (*GetReq) ProtoMessage 

func (*GetReq) ProtoMessage()

func (*GetReq) Reset 

func (m *GetReq) Reset()

func (*GetReq) String 

func (m *GetReq) String() string

func (*GetReq) XXX_DiscardUnknown 

func (m *GetReq) XXX_DiscardUnknown()

func (*GetReq) XXX_Marshal 

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

func (*GetReq) XXX_Merge 

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

func (*GetReq) XXX_Size 

func (m *GetReq) XXX_Size() int

func (*GetReq) XXX_Unmarshal 

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

type GetResp 

type GetResp 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 (*GetResp) Descriptor 

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

func (*GetResp) GetData 

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

func (*GetResp) ProtoMessage 

func (*GetResp) ProtoMessage()

func (*GetResp) Reset 

func (m *GetResp) Reset()

func (*GetResp) String 

func (m *GetResp) String() string

func (*GetResp) XXX_DiscardUnknown 

func (m *GetResp) XXX_DiscardUnknown()

func (*GetResp) XXX_Marshal 

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

func (*GetResp) XXX_Merge 

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

func (*GetResp) XXX_Size 

func (m *GetResp) XXX_Size() int

func (*GetResp) XXX_Unmarshal 

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

type ListReq 

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

func (*ListReq) Descriptor 

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

func (*ListReq) GetBucketId 

func (m *ListReq) GetBucketId() string

func (*ListReq) ProtoMessage 

func (*ListReq) ProtoMessage()

func (*ListReq) Reset 

func (m *ListReq) Reset()

func (*ListReq) String 

func (m *ListReq) String() string

func (*ListReq) XXX_DiscardUnknown 

func (m *ListReq) XXX_DiscardUnknown()

func (*ListReq) XXX_Marshal 

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

func (*ListReq) XXX_Merge 

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

func (*ListReq) XXX_Size 

func (m *ListReq) XXX_Size() int

func (*ListReq) XXX_Unmarshal 

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

type ListResp 

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

func (*ListResp) Descriptor 

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

func (*ListResp) GetId 

func (m *ListResp) GetId() []string

func (*ListResp) ProtoMessage 

func (*ListResp) ProtoMessage()

func (*ListResp) Reset 

func (m *ListResp) Reset()

func (*ListResp) String 

func (m *ListResp) String() string

func (*ListResp) XXX_DiscardUnknown 

func (m *ListResp) XXX_DiscardUnknown()

func (*ListResp) XXX_Marshal 

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

func (*ListResp) XXX_Merge 

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

func (*ListResp) XXX_Size 

func (m *ListResp) XXX_Size() int

func (*ListResp) XXX_Unmarshal 

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

type PutReq 

type PutReq struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	BucketId             string   `protobuf:"bytes,2,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	Data                 []byte   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PutReq) Descriptor 

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

func (*PutReq) GetBucketId 

func (m *PutReq) GetBucketId() string

func (*PutReq) GetData 

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

func (*PutReq) GetId 

func (m *PutReq) GetId() string

func (*PutReq) ProtoMessage 

func (*PutReq) ProtoMessage()

func (*PutReq) Reset 

func (m *PutReq) Reset()

func (*PutReq) String 

func (m *PutReq) String() string

func (*PutReq) XXX_DiscardUnknown 

func (m *PutReq) XXX_DiscardUnknown()

func (*PutReq) XXX_Marshal 

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

func (*PutReq) XXX_Merge 

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

func (*PutReq) XXX_Size 

func (m *PutReq) XXX_Size() int

func (*PutReq) XXX_Unmarshal 

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

type PutResp 

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

func (*PutResp) Descriptor 

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

func (*PutResp) ProtoMessage 

func (*PutResp) ProtoMessage()

func (*PutResp) Reset 

func (m *PutResp) Reset()

func (*PutResp) String 

func (m *PutResp) String() string

func (*PutResp) XXX_DiscardUnknown 

func (m *PutResp) XXX_DiscardUnknown()

func (*PutResp) XXX_Marshal 

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

func (*PutResp) XXX_Merge 

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

func (*PutResp) XXX_Size 

func (m *PutResp) XXX_Size() int

func (*PutResp) XXX_Unmarshal 

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