agentv1

type AgentAPIClient interface {
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error)
	GracefulShutdown(ctx context.Context, in *GracefulShutdownRequest, opts ...grpc.CallOption) (*GracefulShutdownResponse, error)
	WatchSubscription(ctx context.Context, opts ...grpc.CallOption) (AgentAPI_WatchSubscriptionClient, error)
}

type AgentAPIServer interface {
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)
	GracefulShutdown(context.Context, *GracefulShutdownRequest) (*GracefulShutdownResponse, error)
	WatchSubscription(AgentAPI_WatchSubscriptionServer) error
	// contains filtered or unexported methods
}

type AgentAPI_WatchSubscriptionClient interface {
	Send(*WatchSubscriptionRequest) error
	Recv() (*WatchSubscriptionResponse, error)
	grpc.ClientStream
}

type AgentAPI_WatchSubscriptionServer interface {
	Send(*WatchSubscriptionResponse) error
	Recv() (*WatchSubscriptionRequest, error)
	grpc.ServerStream
}

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

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

type PublishRequest struct {
	Sync      bool     `protobuf:"varint,1,opt,name=sync,proto3" json:"sync,omitempty"`
	Path      string   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Tags      []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	BlockSize int32    `protobuf:"varint,4,opt,name=block_size,json=blockSize,proto3" json:"block_size,omitempty"`
	// contains filtered or unexported fields
}

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

type SubscribeRequest struct {
	Sync bool     `protobuf:"varint,1,opt,name=sync,proto3" json:"sync,omitempty"`
	Path string   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Tags []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

type SubscribeResponse struct {
	Paths map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

type UnimplementedAgentAPIServer struct {
}

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

type WatchSubscriptionRequest struct {
	Subscription *SubscribeRequest `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	Cancel       bool              `protobuf:"varint,2,opt,name=cancel,proto3" json:"cancel,omitempty"`
	// contains filtered or unexported fields
}

type WatchSubscriptionResponse struct {
	Subscription *SubscribeResponse `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	Cancelled    bool               `protobuf:"varint,2,opt,name=cancelled,proto3" json:"cancelled,omitempty"`
	// contains filtered or unexported fields
}