internal

var (
	// READ_ROW executes Point Reads on standard tables.
	READ_ROW = &VRpcDescriptorImpl{
		MethodName: "ReadRow",
		EncodeFn: createTableEncoder(func(req interface{}, env *btpb.TableRequest) {
			args := req.(ReadRowArgs)
			env.Payload = &btpb.TableRequest_ReadRow{
				ReadRow: encodeReadRow(args),
			}
		}),
		DecodeFn: createTableDecoder(func(env *btpb.TableResponse) interface{} {
			return decodeReadRow(env.GetReadRow())
		}),
	}

	// MUTATE_ROW executes Point Mutations on standard tables.
	MUTATE_ROW = &VRpcDescriptorImpl{
		MethodName: "MutateRow",
		EncodeFn: createTableEncoder(func(req interface{}, env *btpb.TableRequest) {
			args := req.(MutateRowArgs)
			env.Payload = &btpb.TableRequest_MutateRow{
				MutateRow: encodeMutateRow(args),
			}
		}),
		DecodeFn: createTableDecoder(func(env *btpb.TableResponse) interface{} {
			return decodeMutateRow(env.GetMutateRow())
		}),
	}

	// READ_ROW_AUTH_VIEW executes Point Reads on Authorized Views.
	READ_ROW_AUTH_VIEW = &VRpcDescriptorImpl{
		MethodName: "ReadRow",
		EncodeFn: createAuthViewEncoder(func(req interface{}, env *btpb.AuthorizedViewRequest) {
			args := req.(ReadRowArgs)
			env.Payload = &btpb.AuthorizedViewRequest_ReadRow{
				ReadRow: encodeReadRow(args),
			}
		}),
		DecodeFn: createAuthViewDecoder(func(env *btpb.AuthorizedViewResponse) interface{} {
			return decodeReadRow(env.GetReadRow())
		}),
	}

	// MUTATE_ROW_AUTH_VIEW executes Point Mutations on Authorized Views.
	MUTATE_ROW_AUTH_VIEW = &VRpcDescriptorImpl{
		MethodName: "MutateRow",
		EncodeFn: createAuthViewEncoder(func(req interface{}, env *btpb.AuthorizedViewRequest) {
			args := req.(MutateRowArgs)
			env.Payload = &btpb.AuthorizedViewRequest_MutateRow{
				MutateRow: encodeMutateRow(args),
			}
		}),
		DecodeFn: createAuthViewDecoder(func(env *btpb.AuthorizedViewResponse) interface{} {
			return decodeMutateRow(env.GetMutateRow())
		}),
	}

	// READ_ROW_MAT_VIEW executes Point Reads on Materialized Views.
	READ_ROW_MAT_VIEW = &VRpcDescriptorImpl{
		MethodName: "ReadRow",
		EncodeFn: createMatViewEncoder(func(req interface{}, env *btpb.MaterializedViewRequest) {
			args := req.(ReadRowArgs)
			env.Payload = &btpb.MaterializedViewRequest_ReadRow{
				ReadRow: encodeReadRow(args),
			}
		}),
		DecodeFn: createMatViewDecoder(func(env *btpb.MaterializedViewResponse) interface{} {
			return decodeReadRow(env.GetReadRow())
		}),
	}
)

var (
	// TABLE_SESSION manages standard table scoped Session streams.
	TABLE_SESSION = &SessionDescriptor{
		Type:       SessionTypeTable,
		MethodName: "OpenTable",
		HeaderKeys: []string{"table_name", "app_profile_id", "permission"},
		LogNameFn: func(req proto.Message) string {
			r, ok := req.(*spb.OpenTableRequest)
			if !ok || r == nil {
				return "TableSession(nil)"
			}
			return fmt.Sprintf("TableSession(table=%s, app_profile=%s, perm=%s)", r.TableName, r.AppProfileId, r.Permission.String())
		},
		MetadataFn: func(req proto.Message) map[string]string {
			r, ok := req.(*spb.OpenTableRequest)
			if !ok || r == nil {
				return nil
			}
			return map[string]string{
				"open_session.payload.table_name":     r.TableName,
				"open_session.payload.app_profile_id": r.AppProfileId,
				"open_session.payload.permission":     r.Permission.String(),
			}
		},
	}

	// AUTHORIZED_VIEW_SESSION manages authorized view scoped Session streams.
	AUTHORIZED_VIEW_SESSION = &SessionDescriptor{
		Type:       SessionTypeAuthorizedView,
		MethodName: "OpenAuthorizedView",
		HeaderKeys: []string{"authorized_view_name", "app_profile_id", "permission"},
		LogNameFn: func(req proto.Message) string {
			r, ok := req.(*spb.OpenAuthorizedViewRequest)
			if !ok || r == nil {
				return "AuthorizedViewSession(nil)"
			}
			return fmt.Sprintf("AuthorizedViewSession(view=%s, app_profile=%s, perm=%s)", r.AuthorizedViewName, r.AppProfileId, r.Permission.String())
		},
		MetadataFn: func(req proto.Message) map[string]string {
			r, ok := req.(*spb.OpenAuthorizedViewRequest)
			if !ok || r == nil {
				return nil
			}
			return map[string]string{
				"open_session.payload.authorized_view_name": r.AuthorizedViewName,
				"open_session.payload.app_profile_id":       r.AppProfileId,
				"open_session.payload.permission":           r.Permission.String(),
			}
		},
	}

	// MATERIALIZED_VIEW_SESSION manages materialized view scoped Session streams (Read-Only).
	MATERIALIZED_VIEW_SESSION = &SessionDescriptor{
		Type:       SessionTypeMaterializedView,
		MethodName: "OpenMaterializedView",
		HeaderKeys: []string{"materialized_view_name", "app_profile_id", "permission"},
		LogNameFn: func(req proto.Message) string {
			r, ok := req.(*spb.OpenMaterializedViewRequest)
			if !ok || r == nil {
				return "MaterializedViewSession(nil)"
			}
			return fmt.Sprintf("MaterializedViewSession(view=%s, app_profile=%s, perm=%s)", r.MaterializedViewName, r.AppProfileId, r.Permission.String())
		},
		MetadataFn: func(req proto.Message) map[string]string {
			r, ok := req.(*spb.OpenMaterializedViewRequest)
			if !ok || r == nil {
				return nil
			}
			return map[string]string{
				"open_session.payload.materialized_view_name": r.MaterializedViewName,
				"open_session.payload.app_profile_id":         r.AppProfileId,
				"open_session.payload.permission":             r.Permission.String(),
			}
		},
	}
)