httpauth

package
v0.0.0-...-eb06b8f Latest Latest
Warning

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

 Go to latest Published: Nov 22, 2024 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AuthServer_ServiceDesc = server.ServiceDesc{
	ServiceName: "demo.httpauth.Auth",
	HandlerType: ((*AuthService)(nil)),
	Methods: []server.Method{
		{
			Name: "/demo/auth/Login",
			Func: AuthService_Login_Handler,
		},
		{
			Name: "/demo/auth/Synchronize",
			Func: AuthService_Synchronize_Handler,
		},
		{
			Name: "/demo.httpauth.Auth/Login",
			Func: AuthService_Login_Handler,
		},
		{
			Name: "/demo.httpauth.Auth/Synchronize",
			Func: AuthService_Synchronize_Handler,
		},
	},
}

AuthServer_ServiceDesc descriptor for server.RegisterService.

View Source 
var File_http_auth_proto protoreflect.FileDescriptor
View Source 
var NewAuthClientProxy = func(opts ...client.Option) AuthClientProxy {
	return &AuthClientProxyImpl{client: client.DefaultClient, opts: opts}
}

Functions

func AuthService_Login_Handler 

func AuthService_Login_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func AuthService_Synchronize_Handler 

func AuthService_Synchronize_Handler(svr interface{}, ctx context.Context, f server.FilterFunc) (interface{}, error)

func RegisterAuthService 

func RegisterAuthService(s server.Service, svr AuthService)

RegisterAuthService registers service.

Types

type AuthClientProxy 

type AuthClientProxy interface {
	Login(ctx context.Context, req *LoginRequest, opts ...client.Option) (rsp *LoginResponse, err error) // @alias=/demo/auth/Login

	Synchronize(ctx context.Context, req *SynchronizeRequest, opts ...client.Option) (rsp *SynchronizeResponse, err error) // @alias=/demo/auth/Synchronize
}

AuthClientProxy defines service client proxy

type AuthClientProxyImpl 

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

func (*AuthClientProxyImpl) Login 

func (c *AuthClientProxyImpl) Login(ctx context.Context, req *LoginRequest, opts ...client.Option) (*LoginResponse, error)

func (*AuthClientProxyImpl) Synchronize 

func (c *AuthClientProxyImpl) Synchronize(ctx context.Context, req *SynchronizeRequest, opts ...client.Option) (*SynchronizeResponse, error)

type AuthService 

type AuthService interface {
	Login(ctx context.Context, req *LoginRequest) (*LoginResponse, error) // @alias=/demo/auth/Login

	Synchronize(ctx context.Context, req *SynchronizeRequest) (*SynchronizeResponse, error) // @alias=/demo/auth/Synchronize
}

AuthService defines service.

type LoginRequest 

type LoginRequest struct {
	Metadata     *common.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Username     string           `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	PasswordHash string           `protobuf:"bytes,3,opt,name=password_hash,json=passwordHash,proto3" json:"password_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginRequest) Descriptor deprecated 

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

Deprecated: Use LoginRequest.ProtoReflect.Descriptor instead.

func (*LoginRequest) GetMetadata 

func (x *LoginRequest) GetMetadata() *common.Metadata

func (*LoginRequest) GetPasswordHash 

func (x *LoginRequest) GetPasswordHash() string

func (*LoginRequest) GetUsername 

func (x *LoginRequest) GetUsername() string

func (*LoginRequest) ProtoMessage 

func (*LoginRequest) ProtoMessage()

func (*LoginRequest) ProtoReflect 

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

func (*LoginRequest) Reset 

func (x *LoginRequest) Reset()

func (*LoginRequest) String 

func (x *LoginRequest) String() string

type LoginResponse 

type LoginResponse struct {
	ErrCode int32               `protobuf:"varint,1,opt,name=err_code,json=errCode,proto3" json:"err_code"`
	ErrMsg  string              `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Data    *LoginResponse_Data `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginResponse) Descriptor deprecated 

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

Deprecated: Use LoginResponse.ProtoReflect.Descriptor instead.

func (*LoginResponse) GetData 

func (x *LoginResponse) GetData() *LoginResponse_Data

func (*LoginResponse) GetErrCode 

func (x *LoginResponse) GetErrCode() int32

func (*LoginResponse) GetErrMsg 

func (x *LoginResponse) GetErrMsg() string

func (*LoginResponse) ProtoMessage 

func (*LoginResponse) ProtoMessage()

func (*LoginResponse) ProtoReflect 

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

func (*LoginResponse) Reset 

func (x *LoginResponse) Reset()

func (*LoginResponse) String 

func (x *LoginResponse) String() string

type LoginResponse_Data 

type LoginResponse_Data struct {
	IdTicket string `protobuf:"bytes,1,opt,name=id_ticket,json=idTicket,proto3" json:"id_ticket,omitempty"`
	// contains filtered or unexported fields
}

func (*LoginResponse_Data) Descriptor deprecated 

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

Deprecated: Use LoginResponse_Data.ProtoReflect.Descriptor instead.

func (*LoginResponse_Data) GetIdTicket 

func (x *LoginResponse_Data) GetIdTicket() string

func (*LoginResponse_Data) ProtoMessage 

func (*LoginResponse_Data) ProtoMessage()

func (*LoginResponse_Data) ProtoReflect 

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

func (*LoginResponse_Data) Reset 

func (x *LoginResponse_Data) Reset()

func (*LoginResponse_Data) String 

func (x *LoginResponse_Data) String() string

type SynchronizeRequest 

type SynchronizeRequest struct {
	Metadata *common.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*SynchronizeRequest) Descriptor deprecated 

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

Deprecated: Use SynchronizeRequest.ProtoReflect.Descriptor instead.

func (*SynchronizeRequest) GetMetadata 

func (x *SynchronizeRequest) GetMetadata() *common.Metadata

func (*SynchronizeRequest) ProtoMessage 

func (*SynchronizeRequest) ProtoMessage()

func (*SynchronizeRequest) ProtoReflect 

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

func (*SynchronizeRequest) Reset 

func (x *SynchronizeRequest) Reset()

func (*SynchronizeRequest) String 

func (x *SynchronizeRequest) String() string

type SynchronizeResponse 

type SynchronizeResponse struct {
	ErrCode int32                     `protobuf:"varint,1,opt,name=err_code,json=errCode,proto3" json:"err_code"`
	ErrMsg  string                    `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	Data    *SynchronizeResponse_Data `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SynchronizeResponse) Descriptor deprecated 

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

Deprecated: Use SynchronizeResponse.ProtoReflect.Descriptor instead.

func (*SynchronizeResponse) GetData 

func (x *SynchronizeResponse) GetData() *SynchronizeResponse_Data

func (*SynchronizeResponse) GetErrCode 

func (x *SynchronizeResponse) GetErrCode() int32

func (*SynchronizeResponse) GetErrMsg 

func (x *SynchronizeResponse) GetErrMsg() string

func (*SynchronizeResponse) ProtoMessage 

func (*SynchronizeResponse) ProtoMessage()

func (*SynchronizeResponse) ProtoReflect 

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

func (*SynchronizeResponse) Reset 

func (x *SynchronizeResponse) Reset()

func (*SynchronizeResponse) String 

func (x *SynchronizeResponse) String() string

type SynchronizeResponse_Data 

type SynchronizeResponse_Data struct {
	TsMsec   int64  `protobuf:"varint,1,opt,name=ts_msec,json=tsMsec,proto3" json:"ts_msec,omitempty"` // 毫秒级时间戳
	Timezone string `protobuf:"bytes,2,opt,name=timezone,proto3" json:"timezone,omitempty"`            // 时区
	Env      string `protobuf:"bytes,3,opt,name=env,proto3" json:"env,omitempty"`                      // 环境
	// contains filtered or unexported fields
}

func (*SynchronizeResponse_Data) Descriptor deprecated 

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

Deprecated: Use SynchronizeResponse_Data.ProtoReflect.Descriptor instead.

func (*SynchronizeResponse_Data) GetEnv 

func (x *SynchronizeResponse_Data) GetEnv() string

func (*SynchronizeResponse_Data) GetTimezone 

func (x *SynchronizeResponse_Data) GetTimezone() string

func (*SynchronizeResponse_Data) GetTsMsec 

func (x *SynchronizeResponse_Data) GetTsMsec() int64

func (*SynchronizeResponse_Data) ProtoMessage 

func (*SynchronizeResponse_Data) ProtoMessage()

func (*SynchronizeResponse_Data) ProtoReflect 

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

func (*SynchronizeResponse_Data) Reset 

func (x *SynchronizeResponse_Data) Reset()

func (*SynchronizeResponse_Data) String 

func (x *SynchronizeResponse_Data) String() string

type TestKafkaAddRequest 

type TestKafkaAddRequest struct {
	Metadata *common.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Count    int32            `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*TestKafkaAddRequest) Descriptor deprecated 

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

Deprecated: Use TestKafkaAddRequest.ProtoReflect.Descriptor instead.

func (*TestKafkaAddRequest) GetCount 

func (x *TestKafkaAddRequest) GetCount() int32

func (*TestKafkaAddRequest) GetMetadata 

func (x *TestKafkaAddRequest) GetMetadata() *common.Metadata

func (*TestKafkaAddRequest) ProtoMessage 

func (*TestKafkaAddRequest) ProtoMessage()

func (*TestKafkaAddRequest) ProtoReflect 

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

func (*TestKafkaAddRequest) Reset 

func (x *TestKafkaAddRequest) Reset()

func (*TestKafkaAddRequest) String 

func (x *TestKafkaAddRequest) String() string

type TestKafkaAddResponse 

type TestKafkaAddResponse struct {
	ErrCode int32  `protobuf:"varint,1,opt,name=err_code,json=errCode,proto3" json:"err_code"`
	ErrMsg  string `protobuf:"bytes,2,opt,name=err_msg,json=errMsg,proto3" json:"err_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*TestKafkaAddResponse) Descriptor deprecated 

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

Deprecated: Use TestKafkaAddResponse.ProtoReflect.Descriptor instead.

func (*TestKafkaAddResponse) GetErrCode 

func (x *TestKafkaAddResponse) GetErrCode() int32

func (*TestKafkaAddResponse) GetErrMsg 

func (x *TestKafkaAddResponse) GetErrMsg() string

func (*TestKafkaAddResponse) ProtoMessage 

func (*TestKafkaAddResponse) ProtoMessage()

func (*TestKafkaAddResponse) ProtoReflect 

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

func (*TestKafkaAddResponse) Reset 

func (x *TestKafkaAddResponse) Reset()

func (*TestKafkaAddResponse) String 

func (x *TestKafkaAddResponse) String() string

type UnimplementedAuth 

type UnimplementedAuth struct{}

func (*UnimplementedAuth) Login 

func (s *UnimplementedAuth) Login(ctx context.Context, req *LoginRequest) (*LoginResponse, error)

func (*UnimplementedAuth) Synchronize 

func (s *UnimplementedAuth) Synchronize(ctx context.Context, req *SynchronizeRequest) (*SynchronizeResponse, error)

Source Files

View all Source files

Directories

Path Synopsis
Package mock is a generated GoMock package.
 Package mock is a generated GoMock package.

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.