Documentation
¶
Index ¶
Constants ¶
View Source
const (
ServiceName = "userid.UserService"
)
Variables ¶
View Source
var ClientClass = reflect.TypeOf((*Client)(nil)).Elem()
View Source
var ClientMaxReceiveMessageSize = 1024 * 1024 * 100
Functions ¶
func DialWithLoadBalancer ¶
Types ¶
type Client ¶
type Client interface {
glue.InitializingBean
glue.DisposableBean
//
// Gets metadata about using attributes
//
GetCounts(ctx context.Context, in *emptypb.Empty) (*useridpb.Counts, error)
//
// Quick user lookup request
//
Lookup(ctx context.Context, in *useridpb.LookupRequest) (*useridpb.UserEntity, error)
//
// Search users by indexed non-unique attributes
//
Search(ctx context.Context, in *useridpb.SearchRequest) (entries <-chan UserEntryEvent, cancel func(), err error)
//
// Get user with all attributes
//
Get(ctx context.Context, in *useridpb.GetRequest) (*useridpb.UserEntity, error)
//
// Create user, returns new user_id
//
Create(ctx context.Context, in *useridpb.CreateRequest) (*useridpb.CreateResponse, error)
//
// Delete user request (sets TTL to all PII data for particular user)
//
Delete(ctx context.Context, in *useridpb.DeleteRequest) error
//
// Update user attributes
//
Update(ctx context.Context, in *useridpb.UpdateRequest) error
//
// Scan users
//
Scan(ctx context.Context, in *useridpb.ScanRequest) (entries <-chan UserEntryEvent, cancel func(), err error)
//
// Allocate user id range
//
AddRange(ctx context.Context, in *useridpb.Range) error
//
// Gets user id ranges and etc
//
GetCapacity(ctx context.Context) (*useridpb.Capacity, error)
}
type TokenAuth ¶
type TokenAuth string
func (TokenAuth) GetRequestMetadata ¶
func (TokenAuth) RequireTransportSecurity ¶
type UserEntryEvent ¶
type UserEntryEvent struct {
Err error
Entry *useridpb.UserEntity
}
Click to show internal directories.
Click to hide internal directories.