v1

Documentation

Index

• Constants
• Variables
• func RegisterCacheRepositoryServer(s grpc.ServiceRegistrar, srv CacheRepositoryServer)
• type CacheItem
  • func (*CacheItem) Descriptor() ([]byte, []int)
  • func (x *CacheItem) GetId() string
  • func (*CacheItem) ProtoMessage()
  • func (x *CacheItem) ProtoReflect() protoreflect.Message
  • func (x *CacheItem) Reset()
  • func (x *CacheItem) String() string
• type CacheRepositoryClient
  • func NewCacheRepositoryClient(cc grpc.ClientConnInterface) CacheRepositoryClient
• type CacheRepositoryServer
• type ListRequest
  • func (*ListRequest) Descriptor() ([]byte, []int)
  • func (*ListRequest) ProtoMessage()
  • func (x *ListRequest) ProtoReflect() protoreflect.Message
  • func (x *ListRequest) Reset()
  • func (x *ListRequest) String() string
• type ListResponse
  • func (*ListResponse) Descriptor() ([]byte, []int)
  • func (x *ListResponse) GetItems() map[string]*CacheItem
  • func (*ListResponse) ProtoMessage()
  • func (x *ListResponse) ProtoReflect() protoreflect.Message
  • func (x *ListResponse) Reset()
  • func (x *ListResponse) String() string
• type Server
  • func (s *Server) List(ctx context.Context, req *ListRequest) (*ListResponse, error)
• type UnimplementedCacheRepositoryServer
  • func (UnimplementedCacheRepositoryServer) List(context.Context, *ListRequest) (*ListResponse, error)
• type UnsafeCacheRepositoryServer

Constants

const (
	CacheRepository_List_FullMethodName = "/cache_repository_v1.CacheRepository/List"
)

Variables

var CacheRepository_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cache_repository_v1.CacheRepository",
	HandlerType: (*CacheRepositoryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "List",
			Handler:    _CacheRepository_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/nginx/cache_repository/v1/cache_repository.proto",
}

CacheRepository_ServiceDesc is the grpc.ServiceDesc for CacheRepository service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

var File_internal_nginx_cache_repository_v1_cache_repository_proto protoreflect.FileDescriptor

Functions

func RegisterCacheRepositoryServer

func RegisterCacheRepositoryServer(s grpc.ServiceRegistrar, srv CacheRepositoryServer)

Types

type CacheItem

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

func (*CacheItem) Descriptor

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

Deprecated: Use CacheItem.ProtoReflect.Descriptor instead.

func (*CacheItem) GetId

func (x *CacheItem) GetId() string

func (*CacheItem) ProtoMessage

func (*CacheItem) ProtoMessage()

func (*CacheItem) ProtoReflect

func (x *CacheItem) ProtoReflect() protoreflect.Message

func (*CacheItem) Reset

func (x *CacheItem) Reset()

func (*CacheItem) String

func (x *CacheItem) String() string

type CacheRepositoryClient

type CacheRepositoryClient interface {
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
}

CacheRepositoryClient is the client API for CacheRepository service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCacheRepositoryClient

func NewCacheRepositoryClient(cc grpc.ClientConnInterface) CacheRepositoryClient

type CacheRepositoryServer

type CacheRepositoryServer interface {
	List(context.Context, *ListRequest) (*ListResponse, error)
	// contains filtered or unexported methods
}

CacheRepositoryServer is the server API for CacheRepository service. All implementations must embed UnimplementedCacheRepositoryServer for forward compatibility

type ListRequest

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

func (*ListRequest) Descriptor

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) ProtoMessage

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect

func (x *ListRequest) ProtoReflect() protoreflect.Message

func (*ListRequest) Reset

func (x *ListRequest) Reset()

func (*ListRequest) String

func (x *ListRequest) String() string

type ListResponse

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

func (*ListResponse) Descriptor

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetItems

func (x *ListResponse) GetItems() map[string]*CacheItem

func (*ListResponse) ProtoMessage

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect

func (x *ListResponse) ProtoReflect() protoreflect.Message

func (*ListResponse) Reset

func (x *ListResponse) Reset()

func (*ListResponse) String

func (x *ListResponse) String() string

type Server

type Server struct {
	*UnimplementedCacheRepositoryServer
	Cache  *cr.CacheWatcher
	Logger *zap.Logger
}

func (*Server) List

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

type UnimplementedCacheRepositoryServer

type UnimplementedCacheRepositoryServer struct {
}

UnimplementedCacheRepositoryServer must be embedded to have forward compatible implementations.

func (UnimplementedCacheRepositoryServer) List

func (UnimplementedCacheRepositoryServer) List(context.Context, *ListRequest) (*ListResponse, error)

type UnsafeCacheRepositoryServer

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

UnsafeCacheRepositoryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CacheRepositoryServer will result in compilation errors.