watcherv1

type CreateWatcherRequest struct {
	Watch *WatcherDetails `protobuf:"bytes,1,opt,name=watch,proto3" json:"watch,omitempty"`
	// contains filtered or unexported fields
}

type CreateWatcherResponse struct {
	Watch *WatcherDetails `protobuf:"bytes,1,opt,name=watch,proto3" json:"watch,omitempty"`
	// contains filtered or unexported fields
}

type DeleteWatcherRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteWatcherResponse struct {
	Watch *WatcherDetails `protobuf:"bytes,1,opt,name=watch,proto3" json:"watch,omitempty"`
	// contains filtered or unexported fields
}

type DocumentDetails struct {
	Metadata  *DocumentMetadata      `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Removed   bool                   `protobuf:"varint,3,opt,name=removed,proto3" json:"removed,omitempty"`
	Digest    string                 `protobuf:"bytes,4,opt,name=digest,proto3" json:"digest,omitempty"`
	Url       string                 `protobuf:"bytes,5,opt,name=url,proto3" json:"url,omitempty"`
	// contains filtered or unexported fields
}

type DocumentMetadata struct {
	Name    string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Date    string    `protobuf:"bytes,2,opt,name=date,proto3" json:"date,omitempty"`
	Format  v1.Format `protobuf:"varint,3,opt,name=format,proto3,enum=core.v1.Format" json:"format,omitempty"`
	Version string    `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type Documents struct {
	Document    []*DocumentDetails     `protobuf:"bytes,1,rep,name=document,proto3" json:"document,omitempty"`
	LastUpdated *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"`
	// contains filtered or unexported fields
}

type Entries struct {
	Documents map[string]*Documents `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

type GetWatcherRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type GetWatcherResponse struct {
	Watch *WatcherDetails `protobuf:"bytes,1,opt,name=watch,proto3" json:"watch,omitempty"`
	// contains filtered or unexported fields
}

type Index struct {

	// url where index is stored (i.e gs://<project-name>-index/index.json)
	Url         string                 `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Count       int64                  `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	LastUpdated *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"`
	Entries     *Entries               `protobuf:"bytes,4,opt,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

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

type ListWatchersResponse struct {
	Watches []*WatcherDetails `protobuf:"bytes,1,rep,name=watches,proto3" json:"watches,omitempty"`
	// contains filtered or unexported fields
}

type Metadata struct {
	Id                string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name              string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	CreationTimestamp string `protobuf:"bytes,3,opt,name=creationTimestamp,proto3" json:"creationTimestamp,omitempty"`
	// contains filtered or unexported fields
}

type Spec struct {
	Source *v1.Source `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Index  *Index     `protobuf:"bytes,4,opt,name=index,proto3" json:"index,omitempty"`
	// contains filtered or unexported fields
}

type Status int32

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

type SyncAllResponse struct {
	Sync []*SyncDetails `protobuf:"bytes,1,rep,name=sync,proto3" json:"sync,omitempty"`
	// contains filtered or unexported fields
}

type SyncDetails struct {
	Id     string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name   string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Status Status `protobuf:"varint,3,opt,name=status,proto3,enum=shorted.service.watcher.v1.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type SyncStatus struct {
	Status Status `protobuf:"varint,3,opt,name=status,proto3,enum=shorted.service.watcher.v1.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type SyncWatcherRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type SyncWatcherResponse struct {
	Sync *SyncDetails `protobuf:"bytes,1,opt,name=sync,proto3" json:"sync,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedWatchServiceServer struct {
}

type UnsafeWatchServiceServer interface {
	// contains filtered or unexported methods
}

type UpdateWatcherRequest struct {
	Id    string          `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Watch *WatcherDetails `protobuf:"bytes,2,opt,name=watch,proto3" json:"watch,omitempty"`
	// contains filtered or unexported fields
}

type UpdateWatcherResponse struct {
	Watch *WatcherDetails `protobuf:"bytes,1,opt,name=watch,proto3" json:"watch,omitempty"`
	// contains filtered or unexported fields
}

type WatchServiceClient interface {
	// A unary RPC used to fetch a list of existing watches
	ListWatchers(ctx context.Context, in *ListWatchersRequest, opts ...grpc.CallOption) (*ListWatchersResponse, error)
	// A unary RPC used to fetch a specific watcherby watch ID
	GetWatcher(ctx context.Context, in *GetWatcherRequest, opts ...grpc.CallOption) (*GetWatcherResponse, error)
	// A unary RPC to create a new watch source.
	CreateWatcher(ctx context.Context, in *CreateWatcherRequest, opts ...grpc.CallOption) (*CreateWatcherResponse, error)
	// A unary RPC to delete a watch source.
	DeleteWatcher(ctx context.Context, in *DeleteWatcherRequest, opts ...grpc.CallOption) (*DeleteWatcherResponse, error)
	// A unary RPC to update an existing watch.
	UpdateWatcher(ctx context.Context, in *UpdateWatcherRequest, opts ...grpc.CallOption) (*UpdateWatcherResponse, error)
	// A unary RPC to update an existing watch.
	SyncAll(ctx context.Context, in *SyncAllRequest, opts ...grpc.CallOption) (*SyncAllResponse, error)
	// A unary RPC to update an existing watch.
	SyncWatcher(ctx context.Context, in *SyncWatcherRequest, opts ...grpc.CallOption) (*SyncWatcherResponse, error)
}

type WatchServiceServer interface {
	// A unary RPC used to fetch a list of existing watches
	ListWatchers(context.Context, *ListWatchersRequest) (*ListWatchersResponse, error)
	// A unary RPC used to fetch a specific watcherby watch ID
	GetWatcher(context.Context, *GetWatcherRequest) (*GetWatcherResponse, error)
	// A unary RPC to create a new watch source.
	CreateWatcher(context.Context, *CreateWatcherRequest) (*CreateWatcherResponse, error)
	// A unary RPC to delete a watch source.
	DeleteWatcher(context.Context, *DeleteWatcherRequest) (*DeleteWatcherResponse, error)
	// A unary RPC to update an existing watch.
	UpdateWatcher(context.Context, *UpdateWatcherRequest) (*UpdateWatcherResponse, error)
	// A unary RPC to update an existing watch.
	SyncAll(context.Context, *SyncAllRequest) (*SyncAllResponse, error)
	// A unary RPC to update an existing watch.
	SyncWatcher(context.Context, *SyncWatcherRequest) (*SyncWatcherResponse, error)
	// contains filtered or unexported methods
}

type WatcherDetails struct {
	ApiVersion string      `protobuf:"bytes,1,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
	Metadata   *Metadata   `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Spec       *Spec       `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
	Status     *SyncStatus `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}