provider

package
v1.0.1 Latest Latest
Warning

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

Go to latest
Published: May 28, 2021 License: MIT Imports: 16 Imported by: 0

Documentation

Overview

Package provider is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source
var File_provider_provider_proto protoreflect.FileDescriptor
View Source
var Provider_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "provider.Provider",
	HandlerType: (*ProviderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _Provider_Create_Handler,
		},
		{
			MethodName: "RemoveID",
			Handler:    _Provider_RemoveID_Handler,
		},
		{
			MethodName: "RemoveAccess",
			Handler:    _Provider_RemoveAccess_Handler,
		},
		{
			MethodName: "Verify",
			Handler:    _Provider_Verify_Handler,
		},
		{
			MethodName: "Put",
			Handler:    _Provider_Put_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _Provider_Get_Handler,
		},
		{
			MethodName: "Keys",
			Handler:    _Provider_Keys_Handler,
		},
		{
			MethodName: "RemoveKeys",
			Handler:    _Provider_RemoveKeys_Handler,
		},
		{
			MethodName: "Refresh",
			Handler:    _Provider_Refresh_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "provider/provider.proto",
}

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

Functions

func RegisterProviderHandler

func RegisterProviderHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterProviderHandler registers the http handlers for service Provider to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterProviderHandlerClient

func RegisterProviderHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ProviderClient) error

RegisterProviderHandlerClient registers the http handlers for service Provider to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ProviderClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ProviderClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ProviderClient" to call the correct interceptors.

func RegisterProviderHandlerFromEndpoint

func RegisterProviderHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterProviderHandlerFromEndpoint is same as RegisterProviderHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterProviderHandlerServer

func RegisterProviderHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ProviderServer) error

RegisterProviderHandlerServer registers the http handlers for service Provider to "mux". UnaryRPC :call ProviderServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterProviderHandlerFromEndpoint instead.

func RegisterProviderServer

func RegisterProviderServer(s grpc.ServiceRegistrar, srv ProviderServer)

Types

type CreateRequest

type CreateRequest struct {
	Access  string  `protobuf:"bytes,1,opt,name=access,proto3" json:"access,omitempty"`
	Refresh string  `protobuf:"bytes,2,opt,name=refresh,proto3" json:"refresh,omitempty"`
	Pairs   []*Pair `protobuf:"bytes,3,rep,name=pairs,proto3" json:"pairs,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRequest) Descriptor deprecated

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetAccess

func (x *CreateRequest) GetAccess() string

func (*CreateRequest) GetPairs

func (x *CreateRequest) GetPairs() []*Pair

func (*CreateRequest) GetRefresh

func (x *CreateRequest) GetRefresh() string

func (*CreateRequest) ProtoMessage

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect

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

func (*CreateRequest) Reset

func (x *CreateRequest) Reset()

func (*CreateRequest) String

func (x *CreateRequest) String() string

type CreateResponse

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

func (*CreateResponse) Descriptor deprecated

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) ProtoMessage

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect

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

func (*CreateResponse) Reset

func (x *CreateResponse) Reset()

func (*CreateResponse) String

func (x *CreateResponse) String() string

type GetRequest

type GetRequest struct {
	Access string   `protobuf:"bytes,1,opt,name=access,proto3" json:"access,omitempty"`
	Keys   []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetAccess

func (x *GetRequest) GetAccess() string

func (*GetRequest) GetKeys

func (x *GetRequest) GetKeys() []string

func (*GetRequest) ProtoMessage

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect

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

func (*GetRequest) Reset

func (x *GetRequest) Reset()

func (*GetRequest) String

func (x *GetRequest) String() string

type GetResponse

type GetResponse struct {
	Value []*Value `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetValue

func (x *GetResponse) GetValue() []*Value

func (*GetResponse) ProtoMessage

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect

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

func (*GetResponse) Reset

func (x *GetResponse) Reset()

func (*GetResponse) String

func (x *GetResponse) String() string

type KeysRequest

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

func (*KeysRequest) Descriptor deprecated

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

Deprecated: Use KeysRequest.ProtoReflect.Descriptor instead.

func (*KeysRequest) GetAccess

func (x *KeysRequest) GetAccess() string

func (*KeysRequest) ProtoMessage

func (*KeysRequest) ProtoMessage()

func (*KeysRequest) ProtoReflect

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

func (*KeysRequest) Reset

func (x *KeysRequest) Reset()

func (*KeysRequest) String

func (x *KeysRequest) String() string

type KeysResponse

type KeysResponse struct {
	Result []string `protobuf:"bytes,1,rep,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*KeysResponse) Descriptor deprecated

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

Deprecated: Use KeysResponse.ProtoReflect.Descriptor instead.

func (*KeysResponse) GetResult

func (x *KeysResponse) GetResult() []string

func (*KeysResponse) ProtoMessage

func (*KeysResponse) ProtoMessage()

func (*KeysResponse) ProtoReflect

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

func (*KeysResponse) Reset

func (x *KeysResponse) Reset()

func (*KeysResponse) String

func (x *KeysResponse) String() string

type Pair

type Pair struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Pair) Descriptor deprecated

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

Deprecated: Use Pair.ProtoReflect.Descriptor instead.

func (*Pair) GetKey

func (x *Pair) GetKey() string

func (*Pair) GetValue

func (x *Pair) GetValue() []byte

func (*Pair) ProtoMessage

func (*Pair) ProtoMessage()

func (*Pair) ProtoReflect

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

func (*Pair) Reset

func (x *Pair) Reset()

func (*Pair) String

func (x *Pair) String() string

type ProviderClient

type ProviderClient interface {
	// Store tokens in the backend
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	// Remove token by id
	RemoveID(ctx context.Context, in *RemoveIDRequest, opts ...grpc.CallOption) (*RemoveIDResponse, error)
	// Remove token by access token
	RemoveAccess(ctx context.Context, in *RemoveAccessRequest, opts ...grpc.CallOption) (*RemoveAccessResponse, error)
	// Verify token status
	Verify(ctx context.Context, in *VerifyRequest, opts ...grpc.CallOption) (*VerifyResponse, error)
	// Update the key-value pair associated with the token
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	// Return the key-value pair associated with the token
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Returns the key associated with the token
	Keys(ctx context.Context, in *KeysRequest, opts ...grpc.CallOption) (*KeysResponse, error)
	// Delete the key associated with the token
	RemoveKeys(ctx context.Context, in *RemoveKeysRequest, opts ...grpc.CallOption) (*RemoveKeysResponse, error)
	// Update the token stored in the backend
	Refresh(ctx context.Context, in *RefreshRequest, opts ...grpc.CallOption) (*RefreshResponse, error)
}

ProviderClient is the client API for Provider 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 NewProviderClient

func NewProviderClient(cc grpc.ClientConnInterface) ProviderClient

type ProviderServer

type ProviderServer interface {
	// Store tokens in the backend
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	// Remove token by id
	RemoveID(context.Context, *RemoveIDRequest) (*RemoveIDResponse, error)
	// Remove token by access token
	RemoveAccess(context.Context, *RemoveAccessRequest) (*RemoveAccessResponse, error)
	// Verify token status
	Verify(context.Context, *VerifyRequest) (*VerifyResponse, error)
	// Update the key-value pair associated with the token
	Put(context.Context, *PutRequest) (*PutResponse, error)
	// Return the key-value pair associated with the token
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Returns the key associated with the token
	Keys(context.Context, *KeysRequest) (*KeysResponse, error)
	// Delete the key associated with the token
	RemoveKeys(context.Context, *RemoveKeysRequest) (*RemoveKeysResponse, error)
	// Update the token stored in the backend
	Refresh(context.Context, *RefreshRequest) (*RefreshResponse, error)
	// contains filtered or unexported methods
}

ProviderServer is the server API for Provider service. All implementations must embed UnimplementedProviderServer for forward compatibility

type PutRequest

type PutRequest struct {
	Access string  `protobuf:"bytes,1,opt,name=access,proto3" json:"access,omitempty"`
	Pairs  []*Pair `protobuf:"bytes,2,rep,name=pairs,proto3" json:"pairs,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRequest) Descriptor deprecated

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

Deprecated: Use PutRequest.ProtoReflect.Descriptor instead.

func (*PutRequest) GetAccess

func (x *PutRequest) GetAccess() string

func (*PutRequest) GetPairs

func (x *PutRequest) GetPairs() []*Pair

func (*PutRequest) ProtoMessage

func (*PutRequest) ProtoMessage()

func (*PutRequest) ProtoReflect

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

func (*PutRequest) Reset

func (x *PutRequest) Reset()

func (*PutRequest) String

func (x *PutRequest) String() string

type PutResponse

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

func (*PutResponse) Descriptor deprecated

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

Deprecated: Use PutResponse.ProtoReflect.Descriptor instead.

func (*PutResponse) ProtoMessage

func (*PutResponse) ProtoMessage()

func (*PutResponse) ProtoReflect

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

func (*PutResponse) Reset

func (x *PutResponse) Reset()

func (*PutResponse) String

func (x *PutResponse) String() string

type RefreshRequest

type RefreshRequest struct {
	Access     string `protobuf:"bytes,1,opt,name=access,proto3" json:"access,omitempty"`
	Refresh    string `protobuf:"bytes,2,opt,name=refresh,proto3" json:"refresh,omitempty"`
	NewAccess  string `protobuf:"bytes,3,opt,name=newAccess,proto3" json:"newAccess,omitempty"`
	NewRefresh string `protobuf:"bytes,4,opt,name=newRefresh,proto3" json:"newRefresh,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshRequest) Descriptor deprecated

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

Deprecated: Use RefreshRequest.ProtoReflect.Descriptor instead.

func (*RefreshRequest) GetAccess

func (x *RefreshRequest) GetAccess() string

func (*RefreshRequest) GetNewAccess

func (x *RefreshRequest) GetNewAccess() string

func (*RefreshRequest) GetNewRefresh

func (x *RefreshRequest) GetNewRefresh() string

func (*RefreshRequest) GetRefresh

func (x *RefreshRequest) GetRefresh() string

func (*RefreshRequest) ProtoMessage

func (*RefreshRequest) ProtoMessage()

func (*RefreshRequest) ProtoReflect

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

func (*RefreshRequest) Reset

func (x *RefreshRequest) Reset()

func (*RefreshRequest) String

func (x *RefreshRequest) String() string

type RefreshResponse

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

func (*RefreshResponse) Descriptor deprecated

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

Deprecated: Use RefreshResponse.ProtoReflect.Descriptor instead.

func (*RefreshResponse) ProtoMessage

func (*RefreshResponse) ProtoMessage()

func (*RefreshResponse) ProtoReflect

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

func (*RefreshResponse) Reset

func (x *RefreshResponse) Reset()

func (*RefreshResponse) String

func (x *RefreshResponse) String() string

type RemoveAccessRequest

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

func (*RemoveAccessRequest) Descriptor deprecated

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

Deprecated: Use RemoveAccessRequest.ProtoReflect.Descriptor instead.

func (*RemoveAccessRequest) GetAccess

func (x *RemoveAccessRequest) GetAccess() string

func (*RemoveAccessRequest) ProtoMessage

func (*RemoveAccessRequest) ProtoMessage()

func (*RemoveAccessRequest) ProtoReflect

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

func (*RemoveAccessRequest) Reset

func (x *RemoveAccessRequest) Reset()

func (*RemoveAccessRequest) String

func (x *RemoveAccessRequest) String() string

type RemoveAccessResponse

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

func (*RemoveAccessResponse) Descriptor deprecated

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

Deprecated: Use RemoveAccessResponse.ProtoReflect.Descriptor instead.

func (*RemoveAccessResponse) ProtoMessage

func (*RemoveAccessResponse) ProtoMessage()

func (*RemoveAccessResponse) ProtoReflect

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

func (*RemoveAccessResponse) Reset

func (x *RemoveAccessResponse) Reset()

func (*RemoveAccessResponse) String

func (x *RemoveAccessResponse) String() string

type RemoveIDRequest

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

func (*RemoveIDRequest) Descriptor deprecated

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

Deprecated: Use RemoveIDRequest.ProtoReflect.Descriptor instead.

func (*RemoveIDRequest) GetId

func (x *RemoveIDRequest) GetId() string

func (*RemoveIDRequest) ProtoMessage

func (*RemoveIDRequest) ProtoMessage()

func (*RemoveIDRequest) ProtoReflect

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

func (*RemoveIDRequest) Reset

func (x *RemoveIDRequest) Reset()

func (*RemoveIDRequest) String

func (x *RemoveIDRequest) String() string

type RemoveIDResponse

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

func (*RemoveIDResponse) Descriptor deprecated

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

Deprecated: Use RemoveIDResponse.ProtoReflect.Descriptor instead.

func (*RemoveIDResponse) ProtoMessage

func (*RemoveIDResponse) ProtoMessage()

func (*RemoveIDResponse) ProtoReflect

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

func (*RemoveIDResponse) Reset

func (x *RemoveIDResponse) Reset()

func (*RemoveIDResponse) String

func (x *RemoveIDResponse) String() string

type RemoveKeysRequest

type RemoveKeysRequest struct {
	Access string   `protobuf:"bytes,1,opt,name=access,proto3" json:"access,omitempty"`
	Keys   []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveKeysRequest) Descriptor deprecated

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

Deprecated: Use RemoveKeysRequest.ProtoReflect.Descriptor instead.

func (*RemoveKeysRequest) GetAccess

func (x *RemoveKeysRequest) GetAccess() string

func (*RemoveKeysRequest) GetKeys

func (x *RemoveKeysRequest) GetKeys() []string

func (*RemoveKeysRequest) ProtoMessage

func (*RemoveKeysRequest) ProtoMessage()

func (*RemoveKeysRequest) ProtoReflect

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

func (*RemoveKeysRequest) Reset

func (x *RemoveKeysRequest) Reset()

func (*RemoveKeysRequest) String

func (x *RemoveKeysRequest) String() string

type RemoveKeysResponse

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

func (*RemoveKeysResponse) Descriptor deprecated

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

Deprecated: Use RemoveKeysResponse.ProtoReflect.Descriptor instead.

func (*RemoveKeysResponse) ProtoMessage

func (*RemoveKeysResponse) ProtoMessage()

func (*RemoveKeysResponse) ProtoReflect

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

func (*RemoveKeysResponse) Reset

func (x *RemoveKeysResponse) Reset()

func (*RemoveKeysResponse) String

func (x *RemoveKeysResponse) String() string

type UnimplementedProviderServer

type UnimplementedProviderServer struct {
}

UnimplementedProviderServer must be embedded to have forward compatible implementations.

func (UnimplementedProviderServer) Create

func (UnimplementedProviderServer) Get

func (UnimplementedProviderServer) Keys

func (UnimplementedProviderServer) Put

func (UnimplementedProviderServer) Refresh

func (UnimplementedProviderServer) RemoveAccess

func (UnimplementedProviderServer) RemoveID

func (UnimplementedProviderServer) RemoveKeys

func (UnimplementedProviderServer) Verify

type UnsafeProviderServer

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

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

type Value

type Value struct {
	Bytes  []byte `protobuf:"bytes,1,opt,name=bytes,proto3" json:"bytes,omitempty"`
	Exists bool   `protobuf:"varint,2,opt,name=exists,proto3" json:"exists,omitempty"`
	// contains filtered or unexported fields
}

func (*Value) Descriptor deprecated

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetBytes

func (x *Value) GetBytes() []byte

func (*Value) GetExists

func (x *Value) GetExists() bool

func (*Value) ProtoMessage

func (*Value) ProtoMessage()

func (*Value) ProtoReflect

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

func (*Value) Reset

func (x *Value) Reset()

func (*Value) String

func (x *Value) String() string

type VerifyRequest

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

func (*VerifyRequest) Descriptor deprecated

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

Deprecated: Use VerifyRequest.ProtoReflect.Descriptor instead.

func (*VerifyRequest) GetAccess

func (x *VerifyRequest) GetAccess() string

func (*VerifyRequest) ProtoMessage

func (*VerifyRequest) ProtoMessage()

func (*VerifyRequest) ProtoReflect

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

func (*VerifyRequest) Reset

func (x *VerifyRequest) Reset()

func (*VerifyRequest) String

func (x *VerifyRequest) String() string

type VerifyResponse

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

func (*VerifyResponse) Descriptor deprecated

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

Deprecated: Use VerifyResponse.ProtoReflect.Descriptor instead.

func (*VerifyResponse) ProtoMessage

func (*VerifyResponse) ProtoMessage()

func (*VerifyResponse) ProtoReflect

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

func (*VerifyResponse) Reset

func (x *VerifyResponse) Reset()

func (*VerifyResponse) String

func (x *VerifyResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL