objectserver

type AsyncJob interface {
	GetMethod() string
	GetHeaders() map[string]string
	GetAccount() string
	GetContainer() string
	GetObject() string
}

type AsyncJobMgr interface {
	New(vars, headers map[string]string) AsyncJob

	Save(job AsyncJob) error

	Next(device string, policy int) AsyncJob

	Finish(job AsyncJob) error
}

type CleanAsyncJobMsg struct {
	Job *KVAsyncJob `protobuf:"bytes,4,opt,name=job" json:"job,omitempty"`
}

type CleanAsyncJobReply struct {
	Success bool `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
}

type FSAsyncJob struct {
	Method    string            `pickle:"op"`
	Headers   map[string]string `pickle:"headers"`
	Account   string            `pickle:"account"`
	Container string            `pickle:"container"`
	Object    string            `pickle:"obj"`
	Device    string            `pickle:"device"`
	Policy    int               `pickle:"policy"`
}

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

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

type KVAsyncJob struct {
	Method    string            `protobuf:"bytes,1,opt,name=method" json:"method,omitempty"`
	Headers   map[string]string `` /* 134-byte string literal not displayed */
	Account   string            `protobuf:"bytes,3,opt,name=account" json:"account,omitempty"`
	Container string            `protobuf:"bytes,4,opt,name=container" json:"container,omitempty"`
	Object    string            `protobuf:"bytes,5,opt,name=object" json:"object,omitempty"`
	Device    string            `protobuf:"bytes,6,opt,name=device" json:"device,omitempty"`
	Policy    int32             `protobuf:"varint,7,opt,name=policy" json:"policy,omitempty"`
}

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

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

type KVServiceClient interface {
	SaveAsyncJob(ctx context.Context, in *SaveAsyncJobMsg, opts ...grpc.CallOption) (*SaveAsyncJobReply, error)
	ListAsyncJobs(ctx context.Context, in *ListAsyncJobsMsg, opts ...grpc.CallOption) (*ListAsyncJobsReply, error)
	CleanAsyncJob(ctx context.Context, in *CleanAsyncJobMsg, opts ...grpc.CallOption) (*CleanAsyncJobReply, error)
}

type KVServiceServer interface {
	SaveAsyncJob(context.Context, *SaveAsyncJobMsg) (*SaveAsyncJobReply, error)
	ListAsyncJobs(context.Context, *ListAsyncJobsMsg) (*ListAsyncJobsReply, error)
	CleanAsyncJob(context.Context, *CleanAsyncJobMsg) (*CleanAsyncJobReply, error)
}

type KVStore struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type ListAsyncJobsMsg struct {
	Device     string `protobuf:"bytes,1,opt,name=device" json:"device,omitempty"`
	Policy     int32  `protobuf:"varint,2,opt,name=policy" json:"policy,omitempty"`
	Pagination int32  `protobuf:"varint,3,opt,name=pagination" json:"pagination,omitempty"`
}

type ListAsyncJobsReply struct {
	Jobs []*KVAsyncJob `protobuf:"bytes,1,rep,name=jobs" json:"jobs,omitempty"`
}

type ObjectServer struct {
	http.Server
	// contains filtered or unexported fields
}

type SaveAsyncJobMsg struct {
	Job *KVAsyncJob `protobuf:"bytes,1,opt,name=job" json:"job,omitempty"`
}

type SaveAsyncJobReply struct {
	Success bool `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
}

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