api

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Mar 8, 2023 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthGenerated        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenerated          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenerated = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthRpc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRpc = fmt.Errorf("proto: unexpected end of group")
)

Functions

func NewRBACServiceEndpoints 

func NewRBACServiceEndpoints() []api.Endpoint

API Endpoints for RBACService service

func NewRBACServiceOpenAPI 

func NewRBACServiceOpenAPI() *openapipb.OpenAPI

Swagger OpenAPI 3.0 for RBACService service

func RegisterRBACServiceHandler 

func RegisterRBACServiceHandler(s server.Server, hdlr RBACServiceHandler, opts ...server.HandlerOption) error

func RegisterRBACServiceServer 

func RegisterRBACServiceServer(s *grpc.Server, srv RBACServiceServer)

Types

type AddGroupPolicyRequest 

type AddGroupPolicyRequest struct {
	// +gen:required
	Subject *Subject `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
}

func (*AddGroupPolicyRequest) Descriptor 

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

func (*AddGroupPolicyRequest) Marshal 

func (m *AddGroupPolicyRequest) Marshal() (dAtA []byte, err error)

func (*AddGroupPolicyRequest) MarshalTo 

func (m *AddGroupPolicyRequest) MarshalTo(dAtA []byte) (int, error)

func (*AddGroupPolicyRequest) MarshalToSizedBuffer 

func (m *AddGroupPolicyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddGroupPolicyRequest) ProtoMessage 

func (*AddGroupPolicyRequest) ProtoMessage()

func (*AddGroupPolicyRequest) Reset 

func (m *AddGroupPolicyRequest) Reset()

func (*AddGroupPolicyRequest) String 

func (m *AddGroupPolicyRequest) String() string

func (*AddGroupPolicyRequest) Unmarshal 

func (m *AddGroupPolicyRequest) Unmarshal(dAtA []byte) error

func (*AddGroupPolicyRequest) XSize 

func (m *AddGroupPolicyRequest) XSize() (n int)

func (*AddGroupPolicyRequest) XXX_DiscardUnknown 

func (m *AddGroupPolicyRequest) XXX_DiscardUnknown()

func (*AddGroupPolicyRequest) XXX_Marshal 

func (m *AddGroupPolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddGroupPolicyRequest) XXX_Merge 

func (m *AddGroupPolicyRequest) XXX_Merge(src proto.Message)

func (*AddGroupPolicyRequest) XXX_Size 

func (m *AddGroupPolicyRequest) XXX_Size() int

func (*AddGroupPolicyRequest) XXX_Unmarshal 

func (m *AddGroupPolicyRequest) XXX_Unmarshal(b []byte) error

type AddGroupPolicyResponse 

type AddGroupPolicyResponse struct {
}

func (*AddGroupPolicyResponse) Descriptor 

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

func (*AddGroupPolicyResponse) Marshal 

func (m *AddGroupPolicyResponse) Marshal() (dAtA []byte, err error)

func (*AddGroupPolicyResponse) MarshalTo 

func (m *AddGroupPolicyResponse) MarshalTo(dAtA []byte) (int, error)

func (*AddGroupPolicyResponse) MarshalToSizedBuffer 

func (m *AddGroupPolicyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddGroupPolicyResponse) ProtoMessage 

func (*AddGroupPolicyResponse) ProtoMessage()

func (*AddGroupPolicyResponse) Reset 

func (m *AddGroupPolicyResponse) Reset()

func (*AddGroupPolicyResponse) String 

func (m *AddGroupPolicyResponse) String() string

func (*AddGroupPolicyResponse) Unmarshal 

func (m *AddGroupPolicyResponse) Unmarshal(dAtA []byte) error

func (*AddGroupPolicyResponse) XSize 

func (m *AddGroupPolicyResponse) XSize() (n int)

func (*AddGroupPolicyResponse) XXX_DiscardUnknown 

func (m *AddGroupPolicyResponse) XXX_DiscardUnknown()

func (*AddGroupPolicyResponse) XXX_Marshal 

func (m *AddGroupPolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddGroupPolicyResponse) XXX_Merge 

func (m *AddGroupPolicyResponse) XXX_Merge(src proto.Message)

func (*AddGroupPolicyResponse) XXX_Size 

func (m *AddGroupPolicyResponse) XXX_Size() int

func (*AddGroupPolicyResponse) XXX_Unmarshal 

func (m *AddGroupPolicyResponse) XXX_Unmarshal(b []byte) error

type AddPolicyRequest 

type AddPolicyRequest struct {
	// +gen:required
	Sub string `protobuf:"bytes,1,opt,name=sub,proto3" json:"sub,omitempty"`
	// +gen:required
	Endpoint *api.Endpoint `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
}

func (*AddPolicyRequest) Descriptor 

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

func (*AddPolicyRequest) Marshal 

func (m *AddPolicyRequest) Marshal() (dAtA []byte, err error)

func (*AddPolicyRequest) MarshalTo 

func (m *AddPolicyRequest) MarshalTo(dAtA []byte) (int, error)

func (*AddPolicyRequest) MarshalToSizedBuffer 

func (m *AddPolicyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddPolicyRequest) ProtoMessage 

func (*AddPolicyRequest) ProtoMessage()

func (*AddPolicyRequest) Reset 

func (m *AddPolicyRequest) Reset()

func (*AddPolicyRequest) String 

func (m *AddPolicyRequest) String() string

func (*AddPolicyRequest) Unmarshal 

func (m *AddPolicyRequest) Unmarshal(dAtA []byte) error

func (*AddPolicyRequest) XSize 

func (m *AddPolicyRequest) XSize() (n int)

func (*AddPolicyRequest) XXX_DiscardUnknown 

func (m *AddPolicyRequest) XXX_DiscardUnknown()

func (*AddPolicyRequest) XXX_Marshal 

func (m *AddPolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddPolicyRequest) XXX_Merge 

func (m *AddPolicyRequest) XXX_Merge(src proto.Message)

func (*AddPolicyRequest) XXX_Size 

func (m *AddPolicyRequest) XXX_Size() int

func (*AddPolicyRequest) XXX_Unmarshal 

func (m *AddPolicyRequest) XXX_Unmarshal(b []byte) error

type AddPolicyResponse 

type AddPolicyResponse struct {
}

func (*AddPolicyResponse) Descriptor 

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

func (*AddPolicyResponse) Marshal 

func (m *AddPolicyResponse) Marshal() (dAtA []byte, err error)

func (*AddPolicyResponse) MarshalTo 

func (m *AddPolicyResponse) MarshalTo(dAtA []byte) (int, error)

func (*AddPolicyResponse) MarshalToSizedBuffer 

func (m *AddPolicyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AddPolicyResponse) ProtoMessage 

func (*AddPolicyResponse) ProtoMessage()

func (*AddPolicyResponse) Reset 

func (m *AddPolicyResponse) Reset()

func (*AddPolicyResponse) String 

func (m *AddPolicyResponse) String() string

func (*AddPolicyResponse) Unmarshal 

func (m *AddPolicyResponse) Unmarshal(dAtA []byte) error

func (*AddPolicyResponse) XSize 

func (m *AddPolicyResponse) XSize() (n int)

func (*AddPolicyResponse) XXX_DiscardUnknown 

func (m *AddPolicyResponse) XXX_DiscardUnknown()

func (*AddPolicyResponse) XXX_Marshal 

func (m *AddPolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddPolicyResponse) XXX_Merge 

func (m *AddPolicyResponse) XXX_Merge(src proto.Message)

func (*AddPolicyResponse) XXX_Size 

func (m *AddPolicyResponse) XXX_Size() int

func (*AddPolicyResponse) XXX_Unmarshal 

func (m *AddPolicyResponse) XXX_Unmarshal(b []byte) error

type DelGroupPolicyRequest 

type DelGroupPolicyRequest struct {
	// +gen:required
	Subject *Subject `protobuf:"bytes,1,opt,name=subject,proto3" json:"subject,omitempty"`
}

func (*DelGroupPolicyRequest) Descriptor 

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

func (*DelGroupPolicyRequest) Marshal 

func (m *DelGroupPolicyRequest) Marshal() (dAtA []byte, err error)

func (*DelGroupPolicyRequest) MarshalTo 

func (m *DelGroupPolicyRequest) MarshalTo(dAtA []byte) (int, error)

func (*DelGroupPolicyRequest) MarshalToSizedBuffer 

func (m *DelGroupPolicyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DelGroupPolicyRequest) ProtoMessage 

func (*DelGroupPolicyRequest) ProtoMessage()

func (*DelGroupPolicyRequest) Reset 

func (m *DelGroupPolicyRequest) Reset()

func (*DelGroupPolicyRequest) String 

func (m *DelGroupPolicyRequest) String() string

func (*DelGroupPolicyRequest) Unmarshal 

func (m *DelGroupPolicyRequest) Unmarshal(dAtA []byte) error

func (*DelGroupPolicyRequest) XSize 

func (m *DelGroupPolicyRequest) XSize() (n int)

func (*DelGroupPolicyRequest) XXX_DiscardUnknown 

func (m *DelGroupPolicyRequest) XXX_DiscardUnknown()

func (*DelGroupPolicyRequest) XXX_Marshal 

func (m *DelGroupPolicyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DelGroupPolicyRequest) XXX_Merge 

func (m *DelGroupPolicyRequest) XXX_Merge(src proto.Message)

func (*DelGroupPolicyRequest) XXX_Size 

func (m *DelGroupPolicyRequest) XXX_Size() int

func (*DelGroupPolicyRequest) XXX_Unmarshal 

func (m *DelGroupPolicyRequest) XXX_Unmarshal(b []byte) error

type DelGroupPolicyResponse 

type DelGroupPolicyResponse struct {
}

func (*DelGroupPolicyResponse) Descriptor 

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

func (*DelGroupPolicyResponse) Marshal 

func (m *DelGroupPolicyResponse) Marshal() (dAtA []byte, err error)

func (*DelGroupPolicyResponse) MarshalTo 

func (m *DelGroupPolicyResponse) MarshalTo(dAtA []byte) (int, error)

func (*DelGroupPolicyResponse) MarshalToSizedBuffer 

func (m *DelGroupPolicyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DelGroupPolicyResponse) ProtoMessage 

func (*DelGroupPolicyResponse) ProtoMessage()

func (*DelGroupPolicyResponse) Reset 

func (m *DelGroupPolicyResponse) Reset()

func (*DelGroupPolicyResponse) String 

func (m *DelGroupPolicyResponse) String() string

func (*DelGroupPolicyResponse) Unmarshal 

func (m *DelGroupPolicyResponse) Unmarshal(dAtA []byte) error

func (*DelGroupPolicyResponse) XSize 

func (m *DelGroupPolicyResponse) XSize() (n int)

func (*DelGroupPolicyResponse) XXX_DiscardUnknown 

func (m *DelGroupPolicyResponse) XXX_DiscardUnknown()

func (*DelGroupPolicyResponse) XXX_Marshal 

func (m *DelGroupPolicyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DelGroupPolicyResponse) XXX_Merge 

func (m *DelGroupPolicyResponse) XXX_Merge(src proto.Message)

func (*DelGroupPolicyResponse) XXX_Size 

func (m *DelGroupPolicyResponse) XXX_Size() int

func (*DelGroupPolicyResponse) XXX_Unmarshal 

func (m *DelGroupPolicyResponse) XXX_Unmarshal(b []byte) error

type EnforceRequest 

type EnforceRequest struct {
	// +gen:required
	Sub string `protobuf:"bytes,1,opt,name=sub,proto3" json:"sub,omitempty"`
	// +gen:required
	Endpoint *api.Endpoint `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
}

func (*EnforceRequest) Descriptor 

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

func (*EnforceRequest) Marshal 

func (m *EnforceRequest) Marshal() (dAtA []byte, err error)

func (*EnforceRequest) MarshalTo 

func (m *EnforceRequest) MarshalTo(dAtA []byte) (int, error)

func (*EnforceRequest) MarshalToSizedBuffer 

func (m *EnforceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EnforceRequest) ProtoMessage 

func (*EnforceRequest) ProtoMessage()

func (*EnforceRequest) Reset 

func (m *EnforceRequest) Reset()

func (*EnforceRequest) String 

func (m *EnforceRequest) String() string

func (*EnforceRequest) Unmarshal 

func (m *EnforceRequest) Unmarshal(dAtA []byte) error

func (*EnforceRequest) XSize 

func (m *EnforceRequest) XSize() (n int)

func (*EnforceRequest) XXX_DiscardUnknown 

func (m *EnforceRequest) XXX_DiscardUnknown()

func (*EnforceRequest) XXX_Marshal 

func (m *EnforceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EnforceRequest) XXX_Merge 

func (m *EnforceRequest) XXX_Merge(src proto.Message)

func (*EnforceRequest) XXX_Size 

func (m *EnforceRequest) XXX_Size() int

func (*EnforceRequest) XXX_Unmarshal 

func (m *EnforceRequest) XXX_Unmarshal(b []byte) error

type EnforceResponse 

type EnforceResponse struct {
	Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
}

func (*EnforceResponse) Descriptor 

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

func (*EnforceResponse) Marshal 

func (m *EnforceResponse) Marshal() (dAtA []byte, err error)

func (*EnforceResponse) MarshalTo 

func (m *EnforceResponse) MarshalTo(dAtA []byte) (int, error)

func (*EnforceResponse) MarshalToSizedBuffer 

func (m *EnforceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EnforceResponse) ProtoMessage 

func (*EnforceResponse) ProtoMessage()

func (*EnforceResponse) Reset 

func (m *EnforceResponse) Reset()

func (*EnforceResponse) String 

func (m *EnforceResponse) String() string

func (*EnforceResponse) Unmarshal 

func (m *EnforceResponse) Unmarshal(dAtA []byte) error

func (*EnforceResponse) XSize 

func (m *EnforceResponse) XSize() (n int)

func (*EnforceResponse) XXX_DiscardUnknown 

func (m *EnforceResponse) XXX_DiscardUnknown()

func (*EnforceResponse) XXX_Marshal 

func (m *EnforceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EnforceResponse) XXX_Merge 

func (m *EnforceResponse) XXX_Merge(src proto.Message)

func (*EnforceResponse) XXX_Size 

func (m *EnforceResponse) XXX_Size() int

func (*EnforceResponse) XXX_Unmarshal 

func (m *EnforceResponse) XXX_Unmarshal(b []byte) error

type PType 

type PType string
const (
	Role   PType = "g"
	Group  PType = "g2"
	Policy PType = "p"
)

type RBACService 

type RBACService interface {
	AddPolicy(ctx context.Context, in *AddPolicyRequest, opts ...client.CallOption) (*AddPolicyResponse, error)
	AddGroupPolicy(ctx context.Context, in *AddGroupPolicyRequest, opts ...client.CallOption) (*AddGroupPolicyResponse, error)
	DelGroupPolicy(ctx context.Context, in *DelGroupPolicyRequest, opts ...client.CallOption) (*DelGroupPolicyResponse, error)
	Enforce(ctx context.Context, in *EnforceRequest, opts ...client.CallOption) (*EnforceResponse, error)
}

Client API for RBACService service +gen:openapi

func NewRBACService 

func NewRBACService(name string, c client.Client) RBACService

type RBACServiceClient 

type RBACServiceClient interface {
	AddPolicy(ctx context.Context, in *AddPolicyRequest, opts ...grpc.CallOption) (*AddPolicyResponse, error)
	AddGroupPolicy(ctx context.Context, in *AddGroupPolicyRequest, opts ...grpc.CallOption) (*AddGroupPolicyResponse, error)
	DelGroupPolicy(ctx context.Context, in *DelGroupPolicyRequest, opts ...grpc.CallOption) (*DelGroupPolicyResponse, error)
	Enforce(ctx context.Context, in *EnforceRequest, opts ...grpc.CallOption) (*EnforceResponse, error)
}

RBACServiceClient is the client API for RBACService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRBACServiceClient 

func NewRBACServiceClient(cc *grpc.ClientConn) RBACServiceClient

type RBACServiceHandler 

type RBACServiceHandler interface {
	AddPolicy(context.Context, *AddPolicyRequest, *AddPolicyResponse) error
	AddGroupPolicy(context.Context, *AddGroupPolicyRequest, *AddGroupPolicyResponse) error
	DelGroupPolicy(context.Context, *DelGroupPolicyRequest, *DelGroupPolicyResponse) error
	Enforce(context.Context, *EnforceRequest, *EnforceResponse) error
}

Server API for RBACService service +gen:openapi

type RBACServiceServer 

type RBACServiceServer interface {
	AddPolicy(context.Context, *AddPolicyRequest) (*AddPolicyResponse, error)
	AddGroupPolicy(context.Context, *AddGroupPolicyRequest) (*AddGroupPolicyResponse, error)
	DelGroupPolicy(context.Context, *DelGroupPolicyRequest) (*DelGroupPolicyResponse, error)
	Enforce(context.Context, *EnforceRequest) (*EnforceResponse, error)
}

RBACServiceServer is the server API for RBACService service.

type Subject 

type Subject struct {
	PType PType  `json:"ptype" protobuf:"bytes,1,opt,name=ptype,proto3,casttype=PType"`
	User  string `json:"user" protobuf:"bytes,2,opt,name=user,proto3"`
	Group string `json:"group" protobuf:"bytes,3,opt,name=group,proto3"`
}

+gogo:genproto=true

func (*Subject) Descriptor 

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

func (*Subject) Marshal 

func (m *Subject) Marshal() (dAtA []byte, err error)

func (*Subject) MarshalTo 

func (m *Subject) MarshalTo(dAtA []byte) (int, error)

func (*Subject) MarshalToSizedBuffer 

func (m *Subject) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Subject) ProtoMessage 

func (*Subject) ProtoMessage()

func (*Subject) Reset 

func (m *Subject) Reset()

func (*Subject) String 

func (m *Subject) String() string

func (*Subject) Unmarshal 

func (m *Subject) Unmarshal(dAtA []byte) error

func (*Subject) XSize 

func (m *Subject) XSize() (n int)

func (*Subject) XXX_DiscardUnknown 

func (m *Subject) XXX_DiscardUnknown()

func (*Subject) XXX_Marshal 

func (m *Subject) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Subject) XXX_Merge 

func (m *Subject) XXX_Merge(src proto.Message)

func (*Subject) XXX_Size 

func (m *Subject) XXX_Size() int

func (*Subject) XXX_Unmarshal 

func (m *Subject) XXX_Unmarshal(b []byte) error

type UnimplementedRBACServiceServer 

type UnimplementedRBACServiceServer struct {
}

UnimplementedRBACServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRBACServiceServer) AddGroupPolicy 

func (*UnimplementedRBACServiceServer) AddGroupPolicy(ctx context.Context, req *AddGroupPolicyRequest) (*AddGroupPolicyResponse, error)

func (*UnimplementedRBACServiceServer) AddPolicy 

func (*UnimplementedRBACServiceServer) AddPolicy(ctx context.Context, req *AddPolicyRequest) (*AddPolicyResponse, error)

func (*UnimplementedRBACServiceServer) DelGroupPolicy 

func (*UnimplementedRBACServiceServer) DelGroupPolicy(ctx context.Context, req *DelGroupPolicyRequest) (*DelGroupPolicyResponse, error)

func (*UnimplementedRBACServiceServer) Enforce 

func (*UnimplementedRBACServiceServer) Enforce(ctx context.Context, req *EnforceRequest) (*EnforceResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.